package amqp-client-async

  1. Overview
  2. Docs
package amqp-client-async
Legend:
Library
Module
Module type
Parameter
Class
Class type

Internal

type channel_no = int
type content_handler = (data * string) -> unit
type method_handler = data -> unit
type close_handler = string -> unit Thread.Deferred.t
type t
val send_heartbeat : t -> unit Thread.Deferred.t
val register_method_handler : (t * channel_no) -> Amqp_client_lib.Types.message_id -> method_handler -> unit
val register_content_handler : (t * channel_no) -> Amqp_client_lib.Types.class_id -> content_handler -> unit
val deregister_method_handler : (t * channel_no) -> Amqp_client_lib.Types.message_id -> unit
val deregister_content_handler : (t * channel_no) -> Amqp_client_lib.Types.class_id -> unit
val set_flow : t -> channel_no -> bool -> unit
val set_flow_all : t -> bool -> unit
val open_channel : t -> channel_no -> unit Thread.Deferred.t
val close_channel : t -> channel_no -> unit Thread.Deferred.t
val flush_channel : t -> channel_no -> unit Thread.Deferred.t
val flush : t -> unit Thread.Deferred.t
val id : t -> string
val init : id:string -> Thread.Reader.t -> Thread.Writer.t -> t
val start : t -> close_handler -> unit Thread.Deferred.t
val close : t -> unit Thread.Deferred.t
val set_max_length : t -> int -> unit