Safe Haskell	Safe-Inferred
Language	Haskell2010

Network.AMQP.Worker.Connection

Synopsis

Documentation

Constructors

Connection
Fields amqpConn :: MVar Connection pool :: Pool Channel exchange :: ExchangeName

Represents the parameters to connect to a broker or a cluster of brokers. See defaultConnectionOpts.

Constructors

Fields

coServers :: ![(String, PortNumber)]
A list of host-port pairs. Useful in a clustered setup to connect to the first available host.
coVHost :: !Text
The VHost to connect to.
coAuth :: ![SASLMechanism]
The SASLMechanisms to use for authenticating with the broker.
coMaxFrameSize :: !(Maybe Word32)
The maximum frame size to be used. If not specified, no limit is assumed.
coHeartbeatDelay :: !(Maybe Word16)
The delay in seconds, after which the client expects a heartbeat frame from the broker. If Nothing, the value suggested by the broker is used. Use Just 0 to disable the heartbeat mechnism.
coMaxChannel :: !(Maybe Word16)
The maximum number of channels the client will use.
coTLSSettings :: Maybe TLSSettings
Whether or not to connect to servers using TLS. See http://www.rabbitmq.com/ssl.html for details.
coName :: !(Maybe Text)
optional connection name (will be displayed in the RabbitMQ web interface)

Constructs default connection options with the following settings :

Broker: amqp://guest:guest@localhost:5672/%2F using the PLAIN SASL mechanism
max frame size: 131072
use the heartbeat delay suggested by the broker
no limit on the number of used channels

Connect to the AMQP server.

conn <- connect (fromURI "amqp://guest:guest@localhost:5672")

Perform an action with a channel resource, and give it back at the end