sig
type queue_name = string
type 'a declare_result =
out:(queue_name:Netamqp_queue.queue_name ->
message_count:Netnumber.uint4 ->
consumer_count:Netnumber.uint4 -> 'a) ->
unit -> 'a
val declare_passively_e :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?no_wait:bool ->
unit -> 'a Netamqp_queue.declare_result Uq_engines.engine
val declare_passively_s :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?no_wait:bool -> unit -> 'a Netamqp_queue.declare_result
val declare_e :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?durable:bool ->
?exclusive:bool ->
?auto_delete:bool ->
?no_wait:bool ->
?arguments:Netamqp_rtypes.table ->
unit -> 'a Netamqp_queue.declare_result Uq_engines.engine
val declare_s :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?durable:bool ->
?exclusive:bool ->
?auto_delete:bool ->
?no_wait:bool ->
?arguments:Netamqp_rtypes.table ->
unit -> 'a Netamqp_queue.declare_result
val bind_e :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string ->
?no_wait:bool ->
?arguments:Netamqp_rtypes.table -> unit -> unit Uq_engines.engine
val bind_s :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string ->
?no_wait:bool -> ?arguments:Netamqp_rtypes.table -> unit -> unit
val unbind_e :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string ->
?arguments:Netamqp_rtypes.table -> unit -> unit Uq_engines.engine
val unbind_s :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
exchange:Netamqp_exchange.exchange_name ->
routing_key:string -> ?arguments:Netamqp_rtypes.table -> unit -> unit
val purge_e :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?no_wait:bool -> unit -> Netnumber.uint4 Uq_engines.engine
val purge_s :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?no_wait:bool -> unit -> Netnumber.uint4
val delete_e :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?if_unused:bool ->
?if_empty:bool ->
?no_wait:bool -> unit -> Netnumber.uint4 Uq_engines.engine
val delete_s :
channel:Netamqp_channel.channel_obj ->
queue:Netamqp_queue.queue_name ->
?if_unused:bool ->
?if_empty:bool -> ?no_wait:bool -> unit -> Netnumber.uint4
end
