Safe Haskell | None |
---|
- emit :: QueueEmitter -> Document -> IO ()
- nextFromQueue :: QueueWorker -> IO Document
- createEmitter :: DBRunner -> IO QueueEmitter
- mkEmitter :: EmitterOpts -> DBRunner -> IO QueueEmitter
- data EmitterOpts = EmitterOpts {}
- createWorker :: DBRunner -> IO QueueWorker
- mkWorker :: WorkerOpts -> DBRunner -> IO QueueWorker
- data WorkerOpts = WorkerOpts {}
Documentation
nextFromQueue :: QueueWorker -> IO DocumentSource
Get the next message from the queue. First marks the message as handled.
Do not call this from multiple threads against the same QueueWorker
createEmitter :: DBRunner -> IO QueueEmitterSource
create a QueueEmitter
mkEmitter :: EmitterOpts -> DBRunner -> IO QueueEmitterSource
create an emitter with non-default configuration
data EmitterOpts Source
createWorker :: DBRunner -> IO QueueWorkerSource
creates a QueueWorker
Do not work
multiple times against the same QueueWorker
mkWorker :: WorkerOpts -> DBRunner -> IO QueueWorkerSource
create an worker with non-default configuration