Database.MongoDB.Queue

Documentation

work :: QueueWorker -> (Document -> Action IO ()) -> IO ()

Perform the action every time there is a new message. And then marks the message as handled. Does not call ForkIO, blocks the program

Do not call this multiple times against the same QueueWorker

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

emit a message for a worker

peek :: QueueWorker -> IO Document

used for testing. Get the next document, will not mark it as handled Do not peek/work multiple times 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