sig
class type message =
object
method amqp_body : Xdr_mstring.mstring list
method amqp_header : Netamqp_endpoint.props_t
method app_id : string option
method content_encoding : string option
method content_type : string option
method correlation_id : string option
method delivery_mode : int option
method expiration : string option
method headers : Netamqp_rtypes.table option
method message_id : string option
method priority : int option
method reply_to : string option
method timestamp : float option
method typ : string option
method user_id : string option
end
val create_message :
?content_type:string ->
?content_encoding:string ->
?headers:Netamqp_rtypes.table ->
?delivery_mode:int ->
?priority:int ->
?correlation_id:string ->
?reply_to:string ->
?expiration:string ->
?message_id:string ->
?timestamp:float ->
?typ:string ->
?user_id:string ->
?app_id:string -> Xdr_mstring.mstring list -> Netamqp_basic.message
val qos_e :
channel:Netamqp_channel.channel_obj ->
?prefetch_size:int ->
?prefetch_count:int -> ?global:bool -> unit -> unit Uq_engines.engine
val qos_s :
channel:Netamqp_channel.channel_obj ->
?prefetch_size:int -> ?prefetch_count:int -> ?global:bool -> unit -> unit
val consume_e :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?consumer_tag:string ->
?no_local:bool ->
?no_ack:bool ->
?exclusive:bool ->
?no_wait:bool ->
?arguments:Netamqp_rtypes.table -> unit -> string Uq_engines.engine
val consume_s :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?consumer_tag:string ->
?no_local:bool ->
?no_ack:bool ->
?exclusive:bool ->
?no_wait:bool -> ?arguments:Netamqp_rtypes.table -> unit -> string
val cancel_e :
channel:Netamqp_channel.channel_obj ->
consumer_tag:string -> ?no_wait:bool -> unit -> string Uq_engines.engine
val cancel_s :
channel:Netamqp_channel.channel_obj ->
consumer_tag:string -> ?no_wait:bool -> unit -> string
val publish_e :
channel:Netamqp_channel.channel_obj ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string ->
?mandatory:bool ->
?immediate:bool -> Netamqp_basic.message -> unit Uq_engines.engine
val publish_s :
channel:Netamqp_channel.channel_obj ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string ->
?mandatory:bool -> ?immediate:bool -> Netamqp_basic.message -> unit
val on_return :
channel:Netamqp_channel.channel_obj ->
cb:(reply_code:int ->
reply_text:string ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string -> Netamqp_basic.message -> unit) ->
unit -> unit
val on_deliver :
channel:Netamqp_channel.channel_obj ->
cb:(consumer_tag:string ->
delivery_tag:Rtypes.uint8 ->
redelivered:bool ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string -> Netamqp_basic.message -> unit) ->
unit -> unit
type 'a get_message =
out:(delivery_tag:Rtypes.uint8 ->
redelivered:bool ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string ->
message_count:Rtypes.uint4 -> Netamqp_basic.message -> 'a) ->
unit -> 'a
type 'a get_result = [ `Empty | `Message of 'a Netamqp_basic.get_message ]
val get_e :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?no_ack:bool -> unit -> 'a Netamqp_basic.get_result Uq_engines.engine
val get_s :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?no_ack:bool -> unit -> 'a Netamqp_basic.get_result
val ack_e :
channel:Netamqp_channel.channel_obj ->
delivery_tag:Rtypes.uint8 ->
?multiple:bool -> unit -> unit Uq_engines.engine
val ack_s :
channel:Netamqp_channel.channel_obj ->
delivery_tag:Rtypes.uint8 -> ?multiple:bool -> unit -> unit
val reject_e :
channel:Netamqp_channel.channel_obj ->
delivery_tag:Rtypes.uint8 ->
requeue:bool -> unit -> unit Uq_engines.engine
val reject_s :
channel:Netamqp_channel.channel_obj ->
delivery_tag:Rtypes.uint8 -> requeue:bool -> unit -> unit
val recover_e :
channel:Netamqp_channel.channel_obj ->
requeue:bool -> unit -> unit Uq_engines.engine
val recover_s :
channel:Netamqp_channel.channel_obj -> requeue:bool -> unit -> unit
end
