Internal
type message = | Method of Amqp_client_lib.Types.message_id * Amqp_client_lib.Io.Input.t| Content of Amqp_client_lib.Types.class_id * Amqp_client_lib.Io.Input.t * stringtype data = Amqp_client_lib.Io.Input.ttype content_handler = (data * string) -> unittype method_handler = data -> unittype close_handler = string -> unit Thread.Deferred.tval write_message :
(t * channel_no) ->
(Amqp_client_lib.Types.message_id
* (Amqp_client_lib.Io.Output.t ->
Amqp_client_lib.Io.Output.t)) ->
(Amqp_client_lib.Types.class_id
* (Amqp_client_lib.Io.Output.t ->
Amqp_client_lib.Io.Output.t)
* string)
option ->
unit Thread.Deferred.tval send_heartbeat : t -> unit Thread.Deferred.tval register_method_handler :
(t * channel_no) ->
Amqp_client_lib.Types.message_id ->
method_handler ->
unitval register_content_handler :
(t * channel_no) ->
Amqp_client_lib.Types.class_id ->
content_handler ->
unitval deregister_method_handler :
(t * channel_no) ->
Amqp_client_lib.Types.message_id ->
unitval deregister_content_handler :
(t * channel_no) ->
Amqp_client_lib.Types.class_id ->
unitval set_flow : t -> channel_no -> bool -> unitval set_flow_all : t -> bool -> unitval open_channel : t -> channel_no -> unit Thread.Deferred.tval close_channel : t -> channel_no -> unit Thread.Deferred.tval flush_channel : t -> channel_no -> unit Thread.Deferred.tval flush : t -> unit Thread.Deferred.tval id : t -> stringval init : id:string -> Thread.Reader.t -> Thread.Writer.t -> tval start : t -> close_handler -> unit Thread.Deferred.tval close : t -> unit Thread.Deferred.tval set_max_length : t -> int -> unit