sig
type connector =
[ `Implied | `Inet of string * int | `Sockaddr of Unix.sockaddr ]
type transport_layer =
[ `Custom of
unit ->
Netamqp_transport.amqp_multiplex_controller Uq_engines.engine
| `TCP of Netamqp_endpoint.connector
| `TLS of
Netamqp_endpoint.connector *
(module Netsys_crypto_types.TLS_CONFIG) ]
type endpoint
type state =
[ `Connected of bool
| `Disconnected
| `Disconnecting of bool
| `Error of exn
| `Off ]
type proto_revision_0_9 = [ `One ]
type protocol = [ `AMQP_0_9 of Netamqp_endpoint.proto_revision_0_9 ]
type sync_client_to_server_method_t =
[ `AMQP_0_9 of Netamqp_methods_0_9.sync_client_to_server_method_t ]
type sync_server_to_client_method_t =
[ `AMQP_0_9 of Netamqp_methods_0_9.sync_server_to_client_method_t ]
type sync_client_initiated_method_t =
[ `AMQP_0_9 of Netamqp_methods_0_9.sync_client_initiated_method_t ]
type sync_server_initiated_method_t =
[ `AMQP_0_9 of Netamqp_methods_0_9.sync_server_initiated_method_t ]
type sync_server_initiated_method_type_t =
[ `AMQP_0_9 of Netamqp_methods_0_9.sync_server_initiated_method_type_t ]
type async_client_to_server_method_t =
[ `AMQP_0_9 of Netamqp_methods_0_9.async_client_to_server_method_t ]
type async_server_to_client_method_t =
[ `AMQP_0_9 of Netamqp_methods_0_9.async_server_to_client_method_t ]
type async_server_to_client_method_type_t =
[ `AMQP_0_9 of Netamqp_methods_0_9.async_server_to_client_method_type_t ]
type method_type_t = [ `AMQP_0_9 of Netamqp_methods_0_9.method_type_t ]
type props_t = [ `AMQP_0_9 of Netamqp_methods_0_9.props_t ]
type data = Netamqp_endpoint.props_t * Netxdr_mstring.mstring list
val create :
Netamqp_endpoint.transport_layer ->
Netamqp_endpoint.protocol ->
Unixqueue.event_system -> Netamqp_endpoint.endpoint
val configure_timeout : Netamqp_endpoint.endpoint -> float -> unit
val get_timeout : Netamqp_endpoint.endpoint -> float
val default_port : int
val connect : Netamqp_endpoint.endpoint -> unit
val disconnect : Netamqp_endpoint.endpoint -> unit
val quick_disconnect : Netamqp_endpoint.endpoint -> unit
val reset : Netamqp_endpoint.endpoint -> unit
val state : Netamqp_endpoint.endpoint -> Netamqp_endpoint.state
val state_change_e :
Netamqp_endpoint.endpoint -> Netamqp_endpoint.state Uq_engines.engine
val event_system : Netamqp_endpoint.endpoint -> Unixqueue.event_system
val protocol : Netamqp_endpoint.endpoint -> Netamqp_endpoint.protocol
val getsockname : Netamqp_endpoint.endpoint -> Netamqp_transport.sockaddr
val getpeername : Netamqp_endpoint.endpoint -> Netamqp_transport.sockaddr
val enable_channel :
Netamqp_endpoint.endpoint -> Netamqp_types.channel -> unit
val disable_channel :
Netamqp_endpoint.endpoint -> Netamqp_types.channel -> unit
val is_channel_enabled :
Netamqp_endpoint.endpoint -> Netamqp_types.channel -> bool
val suggest_channel : Netamqp_endpoint.endpoint -> Netamqp_types.channel
val flow_control :
Netamqp_endpoint.endpoint -> Netamqp_types.channel -> bool -> unit
val drop_frames : Netamqp_endpoint.endpoint -> unit
val clear_output : Netamqp_endpoint.endpoint -> unit
val expect_eof : Netamqp_endpoint.endpoint -> unit
val set_max_frame_size : Netamqp_endpoint.endpoint -> int -> unit
val eff_max_frame_size : Netamqp_endpoint.endpoint -> int
val announce_e : Netamqp_endpoint.endpoint -> unit Uq_engines.engine
val announce_s : Netamqp_endpoint.endpoint -> unit
val sync_c2s_e :
?no_wait:Netamqp_endpoint.sync_server_to_client_method_t ->
?on_timeout:(unit -> unit) ->
Netamqp_endpoint.endpoint ->
Netamqp_endpoint.sync_client_initiated_method_t ->
Netamqp_endpoint.data option ->
Netamqp_types.channel ->
float ->
(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 ->
?on_timeout:(unit -> unit) ->
Netamqp_endpoint.endpoint ->
Netamqp_endpoint.sync_client_initiated_method_t ->
Netamqp_endpoint.data option ->
Netamqp_types.channel ->
float ->
Netamqp_endpoint.sync_server_to_client_method_t *
Netamqp_endpoint.data option
val register_sync_s2c :
Netamqp_endpoint.endpoint ->
Netamqp_endpoint.sync_server_initiated_method_type_t ->
Netamqp_types.channel ->
(Netamqp_endpoint.sync_server_initiated_method_t ->
Netamqp_endpoint.sync_client_to_server_method_t option) ->
(unit -> unit) -> unit
val async_c2s :
Netamqp_endpoint.endpoint ->
Netamqp_endpoint.async_client_to_server_method_t ->
Netamqp_endpoint.data option -> Netamqp_types.channel -> unit
val async_c2s_e :
Netamqp_endpoint.endpoint ->
Netamqp_endpoint.async_client_to_server_method_t ->
Netamqp_endpoint.data option ->
Netamqp_types.channel -> unit Uq_engines.engine
val async_c2s_s :
Netamqp_endpoint.endpoint ->
Netamqp_endpoint.async_client_to_server_method_t ->
Netamqp_endpoint.data option -> Netamqp_types.channel -> unit
val register_async_s2c :
Netamqp_endpoint.endpoint ->
Netamqp_endpoint.async_server_to_client_method_type_t ->
Netamqp_types.channel ->
(Netamqp_endpoint.async_server_to_client_method_t ->
Netamqp_endpoint.data option -> unit) ->
unit
val propagate_error :
Netamqp_endpoint.endpoint -> exn -> Netamqp_types.channel option -> unit
val abort_and_propagate_error : Netamqp_endpoint.endpoint -> exn -> unit
val listen_for_errors :
Netamqp_endpoint.endpoint ->
Netamqp_types.channel option -> (exn -> bool) -> unit
val create_method_exception :
Netamqp_endpoint.protocol ->
class_id:int -> meth_id:int -> reply_code:int -> reply_text:string -> exn
val tls_session_props :
Netamqp_endpoint.endpoint -> Nettls_support.tls_session_props option
module Debug : sig val enable : bool Pervasives.ref end
val sync : ('a -> 'b Uq_engines.engine) -> 'a -> 'b
end
