amqp-worker-0.3.2

Safe Haskell	None
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 :: MonadBaseControl IO m => Connection -> (Channel -> m b) -> m 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 :: MonadBaseControl IO m => Connection -> (Channel -> m b) -> m b Source #

Perform an action with a channel resource