Safe Haskell | None |
---|
- emit :: QueueEmitter -> Document -> IO ()
- nextFromQueue :: QueueWorker -> IO Document
- createEmitter :: DBRunner -> IO QueueEmitter
- createWorker :: DBRunner -> IO QueueWorker
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
createWorker :: DBRunner -> IO QueueWorkerSource
creates a QueueWorker
Do not work
multiple times against the same QueueWorker