Îõ³h&  2      !"#$%&'()*+,-./01 Safe-Inferred"%&6ÂÉÌÑÔ×ÚÜãïž consumersConfig of a consumer.  consumersResult of processing a job. consumers)Action to take after a job was processed.    Safe-Inferred"%&6ÂÌÑÔ×ÚÜãïÅ consumersID of a consumer. consumersÙRegister consumer in the consumers table, so that it can reserve jobs using acquired ID. consumers$Unregister consumer with a given ID. Safe-Inferred"%&6ÂÌÑÔ×ÚÜãï…# consumers%Exception thrown from a child thread.2 consumersÏException thrown to a thread to stop its execution. All exceptions other than 2 thrown to threads spawned by ' and (+ are propagated back to the parent thread.% consumersRun an action mÏ that returns a finalizer and perform the returned finalizer after the action action completes.& consumersStop execution of a thread.' consumersModified version of 39 that propagates thrown exceptions to the parent thread.( consumersModified version of 49 that propagates thrown exceptions to the parent thread.#$%&'(%#$&'( Safe-Inferred"%&6ÂÌÑÔ×ÚÜãï–- consumers¤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 %( to seamlessly handle the finalization.5 consumersæRun the consumer and also signal whenever the consumer is waiting for getNotification or threadDelay./ consumersâSpawn a thread that generates signals for the dispatcher to probe the database for incoming jobs.0 consumersÞSpawn a thread that monitors working consumers for activity and periodically updates its own.1 consumers0Spawn a thread that reserves and processes jobs.6 consumers8Generate a single SQL query for updating all given jobs.-./01-./01 Safe-Inferred"%&6ÂÌÑÔ×ÚÜãïà  #$%&'(-.-.7      !"#$%&'(()*+,-./0123456789:;9<=>(consumers-2.3.1.0-4cz9v9BUciD8oLNNAwdiaV$Database.PostgreSQL.Consumers.Config&Database.PostgreSQL.Consumers.Consumer#Database.PostgreSQL.Consumers.Utils(Database.PostgreSQL.Consumers.ComponentsDatabase.PostgreSQL.ConsumersConsumerConfig ccJobsTableccConsumersTableccJobSelectors ccJobFetcher ccJobIndexccNotificationChannelccNotificationTimeoutccMaxRunningJobs ccProcessJob ccOnExceptionResultOkFailedAction MarkProcessed RerunAfterRerunAtRemove $fEqResult $fOrdResult $fShowResult $fEqAction $fOrdAction $fShowAction ConsumerIDregisterConsumerunregisterConsumer$fShowConsumerID$fToSQLConsumerID$fFromSQLConsumerID$fPQFormatConsumerID$fEqConsumerID$fOrdConsumerID ThrownFromfinalize stopExecutionforkPgforkP$fExceptionStopExecution$fExceptionThrownFrom$fShowThrownFrom$fShowStopExecution runConsumerrunConsumerWithIdleSignal spawnListener spawnMonitorspawnDispatcher StopExecution+lifted-base-0.2.3.12-5RMtxsXMCfjKFVoZiOxqcdControl.Concurrent.Liftedfork)lifted-threads-1.0-2u1ByHHos2k4NEcyL1yMKt&Control.Concurrent.Thread.Group.LiftedrunConsumerWithMaybeIdleSignalupdateJobsQuery