| Safe Haskell | None |
|---|
Snap.Snaplet.AMQP
- 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.
Instances
| HasAmqpPool (Handler b AmqpState) |
class MonadIO m => HasAmqpPool m whereSource
Methods
getAmqpPool :: m AmqpPoolSource
Instances
| HasAmqpPool (Handler b AmqpState) |