Module `Amqp_client_lwt.Framing`Source

Internal

Sourcetype channel_no = int

Sourcetype 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 * string

Sourcetype data = Amqp_client_lib.Io.Input.t

Sourcetype content_handler = (data * string) -> unit

Sourcetype method_handler = data -> unit

Sourcetype close_handler = string -> unit Thread.Deferred.t

Sourcetype t

Source

val 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.t

Sourceval send_heartbeat : t -> unit Thread.Deferred.t

Source

val register_method_handler : 
  (t * channel_no) ->
  Amqp_client_lib.Types.message_id ->
  method_handler ->
  unit

Source

val register_content_handler : 
  (t * channel_no) ->
  Amqp_client_lib.Types.class_id ->
  content_handler ->
  unit

Source

val deregister_method_handler : 
  (t * channel_no) ->
  Amqp_client_lib.Types.message_id ->
  unit

Source

val deregister_content_handler : 
  (t * channel_no) ->
  Amqp_client_lib.Types.class_id ->
  unit

Sourceval set_flow : t -> channel_no -> bool -> unit

Sourceval set_flow_all : t -> bool -> unit

Sourceval open_channel : t -> channel_no -> unit Thread.Deferred.t

Sourceval close_channel : t -> channel_no -> unit Thread.Deferred.t

Sourceval flush_channel : t -> channel_no -> unit Thread.Deferred.t

Sourceval flush : t -> unit Thread.Deferred.t

Sourceval id : t -> string

Sourceval init : id:string -> Thread.Reader.t -> Thread.Writer.t -> t

Sourceval start : t -> close_handler -> unit Thread.Deferred.t

Sourceval close : t -> unit Thread.Deferred.t

Sourceval set_max_length : t -> int -> unit

package amqp-client-lwt

Module Amqp_client_lwt.FramingSource

Module `Amqp_client_lwt.Framing`Source