Module Amqp_client_async.Message

type message = Spec.Basic.Content.t * string
val string_header : string -> string -> Amqp_client_lib.Types.header
val int_header : string -> int -> Amqp_client_lib.Types.header
type 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 -> message
val ack : _ Channel.t -> t -> unit Thread.Deferred.t

Acknowledge a message. Messages must be acknowledged on the same channel as they are received

val reject : requeue:bool -> _ Channel.t -> t -> unit Thread.Deferred.t

Reject (Nack) a message. Messages must be rejected on the same channel as they are received

parameter requeue

If true, the message will be requeued (default)

val recover : requeue:bool -> _ Channel.t -> unit Thread.Deferred.t

Ask the server to resend or discard all outstanding messages on the channel This is essentially the same as calling nack on all outstanding messages.

parameter requeue

if true messages are redelivered