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