Network.AMQP.Worker.Connection

Documentation

data Connection

Constructors

Connection

Fields

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

data ConnectionOpts

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

Constructors

ConnectionOpts

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)

defaultConnectionOpts :: ConnectionOpts

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 :: MonadIO m => ConnectionOpts -> m Connection

Connect to the AMQP server.

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

disconnect :: MonadIO m => Connection -> m ()

withChannel :: Connection -> (Channel -> IO b) -> IO b

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