Amqp message type and functions
type message = Spec.Basic.Content.t * stringtype t = {delivery_tag : int;redelivered : bool;exchange : string;routing_key : string;message : message;}val make :
?content_type:string ->
?content_encoding:string ->
?headers:Amqp_client_lib.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 ->
messageval ack : _ Channel.t -> t -> unit Thread.Deferred.tAcknowledge a message. Messages must be acknowledged on the same channel as they are received
val reject : requeue:bool -> _ Channel.t -> t -> unit Thread.Deferred.tReject (Nack) a message. Messages must be rejected on the same channel as they are received
val recover : requeue:bool -> _ Channel.t -> unit Thread.Deferred.tAsk the server to resend or discard all outstanding messages on the channel This is essentially the same as calling nack on all outstanding messages.