Plasma GitLab Archive
Projects Blog Knowledge

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 'Netamqp_basic.get_message ]
  val get_e :
    channel:Netamqp_channel.channel_obj ->
    queue:Netamqp_queue.queue_name ->
    ?no_ack:bool -> unit -> 'Netamqp_basic.get_result Uq_engines.engine
  val get_s :
    channel:Netamqp_channel.channel_obj ->
    queue:Netamqp_queue.queue_name ->
    ?no_ack:bool -> unit -> '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
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml