Message (amqp_client_eio.Amqp_client

val string_header : 'a -> string -> 'a * Types.value

val int_header : 'a -> int -> 'a * Types.value

type content = Amqp_client_eio__Spec.Basic.Content.t * string

type deliver = {

consumer_tag : string;

delivery_tag : int;

redelivered : bool;

exchange : string;

routing_key : string;

}

val make : 
  ?content_type:string ->
  ?content_encoding:string ->
  ?headers:Types.table ->
  ?delivery_mode:int ->
  ?priority:int ->
  ?correlation_id:string ->
  ?reply_to:string ->
  ?expiration:int ->
  ?message_id:string ->
  ?timestamp:int ->
  ?amqp_type:string ->
  ?user_id:string ->
  ?app_id:string ->
  string ->
  content

val ack : 'a Channel.t -> ?multiple:bool -> deliver -> unit

val reject : 'a Channel.t -> ?multiple:bool -> requeue:bool -> deliver -> unit

val recover : 'a Channel.t -> requeue:bool -> unit