val connect :
id:string ->
?virtual_host:string ->
?port:int ->
?credentials:(string * string) ->
?heartbeat:int ->
string ->
t Thread.Deferred.tConnect to an Amqp server.
connect ~id:"test" localhost connects to localhost using default guest credentials, with identity "test"
an identifier of the connection used for tracing and debugging
a tuple of username * password. The credentials are transmitted in plain text
Named of the virtual host. Virtual must be defined on the amqp-server prior to connecting them. Default "/"
The port to connect to
Delay between heartbeats in seconds. Lower the number to detect connection loss faster.
If an error occurs an exception is raised. To capture and handle exceptions it is advised to detach a monitor Core.Async.Monitor and handle raised exceptions.
The most important exception is Connection_closed. As the connection is stateful (channels are tied to connections e.g), the connection cannot be re-established without redoing all initalization.
val open_channel :
id:string ->
'a Channel.confirms ->
t ->
'a Channel.t Thread.Deferred.tOpen a new channel.
identifies the channel for tracing and debugging
val close : t -> unit Thread.Deferred.t