-- Hoogle documentation, generated by Haddock
-- See Hoogle, http://www.haskell.org/hoogle/


-- | a queue using MongoDB
--   
--   a queue using MongoDB
@package mongodb-queue
@version 0.1.0.0

module Database.MongoDB.Queue

-- | 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
work :: QueueWorker -> (Document -> Action IO ()) -> IO ()

-- | emit a message for a worker
emit :: QueueEmitter -> Document -> IO ()

-- | used for testing. Get the next document, will not mark it as handled
--   Do not peek/work multiple times against the same QueueWorker
peek :: QueueWorker -> IO Document

-- | create a QueueEmitter
createEmitter :: DBRunner -> IO QueueEmitter

-- | creates a QueueWorker Do not <a>work</a> multiple times against the
--   same QueueWorker
createWorker :: DBRunner -> IO QueueWorker
instance Typeable MongoQueueException
instance Show MongoQueueException
instance Exception MongoQueueException