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

mkEmitter :: EmitterOpts -> DBRunner -> IO QueueEmitter

data EmitterOpts

Constructors

EmitterOpts

Fields

emitterVersion :: Int

emitterCollection :: Collection

Instances

Default EmitterOpts

createWorker :: DBRunner -> IO QueueWorker

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

mkWorker :: WorkerOpts -> DBRunner -> IO QueueWorker

data WorkerOpts

Constructors

WorkerOpts

Fields

workerMaxByteSize :: Int

workerCollection :: Collection

Instances

Default WorkerOpts