amqp-worker-0.4.0: Type-safe AMQP workers

Safe Haskell	Safe-Inferred
Language	Haskell2010

Network.AMQP.Worker.Connection

Synopsis

data Connection = Connection {
- amqpConn :: MVar Connection
- pool :: Pool Channel
- exchange :: ExchangeName
}
connect :: MonadIO m => ConnectionOpts -> m Connection
disconnect :: MonadIO m => Connection -> m ()
withChannel :: Connection -> (Channel -> IO b) -> IO b

Documentation

data Connection Source #

Internal connection details

Constructors

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

connect :: MonadIO m => ConnectionOpts -> m Connection Source #

Connect to the AMQP server.

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

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

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

Perform an action with a channel resource