sig
exception Not_open
exception Error of string
type channel = int
type channel_obj
val open_e :
Netamqp_connection.connection ->
Netamqp_channel.channel -> Netamqp_channel.channel_obj Uq_engines.engine
val open_s :
Netamqp_connection.connection ->
Netamqp_channel.channel -> Netamqp_channel.channel_obj
val open_next_e :
Netamqp_connection.connection ->
Netamqp_channel.channel_obj Uq_engines.engine
val open_next_s :
Netamqp_connection.connection -> Netamqp_channel.channel_obj
val close_e : Netamqp_channel.channel_obj -> unit Uq_engines.engine
val close_s : Netamqp_channel.channel_obj -> unit
val is_open : Netamqp_channel.channel_obj -> bool
val configure_sync_timeout : Netamqp_channel.channel_obj -> float -> unit
val sync_c2s_e :
?no_wait:Netamqp_endpoint.sync_server_to_client_method_t ->
Netamqp_channel.channel_obj ->
Netamqp_endpoint.sync_client_initiated_method_t ->
Netamqp_endpoint.data option ->
(Netamqp_endpoint.sync_server_to_client_method_t *
Netamqp_endpoint.data option)
Uq_engines.engine
val sync_c2s_s :
?no_wait:Netamqp_endpoint.sync_server_to_client_method_t ->
Netamqp_channel.channel_obj ->
Netamqp_endpoint.sync_client_initiated_method_t ->
Netamqp_endpoint.data option ->
Netamqp_endpoint.sync_server_to_client_method_t *
Netamqp_endpoint.data option
val number : Netamqp_channel.channel_obj -> Netamqp_channel.channel
val connection :
Netamqp_channel.channel_obj -> Netamqp_connection.connection
val endpoint : Netamqp_channel.channel_obj -> Netamqp_endpoint.endpoint
val event_system : Netamqp_channel.channel_obj -> Unixqueue.event_system
end
