Database.MongoDB.Queue

Documentation

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

emit a message for a worker

nextFromQueue :: QueueWorker -> IO Document

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 QueueEmitter

create a QueueEmitter

createWorker :: DBRunner -> IO QueueWorker

creates a QueueWorker Do not work multiple times against the same QueueWorker