| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Database.PostgreSQL.Consumers
- runConsumer :: (MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSource -> m (m ())
- module Database.PostgreSQL.Consumers.Config
- module Database.PostgreSQL.Consumers.Utils
Documentation
runConsumer :: (MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSource -> m (m ()) Source
Run the consumer. The purpose of the returned monadic
action is to wait for currently processed jobs and clean up.
This function is best used in conjunction with finalize to
seamlessly handle the finalization.