consumers-2.0.0.1: Concurrent PostgreSQL data consumers

Safe HaskellNone
LanguageHaskell2010

Database.PostgreSQL.Consumers

Synopsis

Documentation

runConsumer :: (MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> 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.