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