| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Snap.Snaplet.AMQP
- initAMQP :: SnapletInit b AmqpState
- runAmqp :: HasAmqpPool m => ((Connection, Channel) -> b) -> m b
- mkAmqpPool :: MonadIO m => Config -> m AmqpPool
- newtype AmqpState = AmqpState {
- amqpPool :: AmqpPool
- class MonadIO m => HasAmqpPool m where
- getAmqpPool :: m AmqpPool
Documentation
initAMQP :: SnapletInit b AmqpState Source
Initialize the AMQP Snaplet.
runAmqp :: HasAmqpPool m => ((Connection, Channel) -> b) -> m b Source
Runs an AMQP action in any monad with a HasAmqpPoolonn instance.
mkAmqpPool :: MonadIO m => Config -> m AmqpPool Source
Constructs a connect from Config.
Instances