Safe Haskell | None |
---|---|
Language | Haskell2010 |
- 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.
class MonadIO m => HasAmqpPool m where Source
getAmqpPool :: m AmqpPool Source