Plasma GitLab Archive
Projects Blog Knowledge

sig
  type queue_name = string
  type 'a declare_result =
      out:(queue_name:Netamqp_queue.queue_name ->
           message_count:Rtypes.uint4 -> consumer_count:Rtypes.uint4 -> 'a) ->
      unit -> 'a
  val declare_passively_e :
    channel:Netamqp_channel.channel_obj ->
    queue:Netamqp_queue.queue_name ->
    ?no_wait:bool ->
    unit -> '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 -> '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 -> '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 -> '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 -> Rtypes.uint4 Uq_engines.engine
  val purge_s :
    channel:Netamqp_channel.channel_obj ->
    queue:Netamqp_queue.queue_name -> ?no_wait:bool -> unit -> Rtypes.uint4
  val delete_e :
    channel:Netamqp_channel.channel_obj ->
    queue:Netamqp_queue.queue_name ->
    ?if_unused:bool ->
    ?if_empty:bool -> ?no_wait:bool -> unit -> Rtypes.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 -> Rtypes.uint4
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml