| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Database.PostgreSQL.Consumers.Consumer
- data ConsumerID
- registerConsumer :: (MonadBase IO m, MonadMask m) => ConsumerConfig n idx job -> ConnectionSource -> m ConsumerID
- unregisterConsumer :: (MonadBase IO m, MonadMask m) => ConsumerConfig n idx job -> ConnectionSource -> ConsumerID -> m ()
Documentation
registerConsumer :: (MonadBase IO m, MonadMask m) => ConsumerConfig n idx job -> ConnectionSource -> m ConsumerID Source
Register consumer in the consumers table, so that it can reserve jobs using acquired ID.
unregisterConsumer :: (MonadBase IO m, MonadMask m) => ConsumerConfig n idx job -> ConnectionSource -> ConsumerID -> m () Source
Unregister consumer with a given ID.