mongodb-queue- a queue using MongoDB

Safe HaskellNone




emit :: QueueEmitter -> Document -> IO ()Source

emit a message for a worker

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