úÎ  ØNoneversion create a QueueEmitter emit a message for a worker creates a QueueWorker  Do not - multiple times against the same QueueWorker used for testing. 4 Get the next document, will not mark it as handled  Do not peek/1work multiple times against the same QueueWorker 6Perform 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 *  !"#$updates %&'()   !"#$%&'()*       !"#$%&'(mongodb-queue-0.1.0.0Database.MongoDB.Queue createEmitteremit createWorkerpeekwork qeVersionMongoQueueExceptionTailableCursorErrorFindAndModifyError WorkerOpts workerRunnerworkerMaxByteSizeworkerCollection QueueWorkerqwRunDBqwCursor qwCollection EmitterOptsemitterVersion emitterRunneremitterCollection QueueEmitterqeHostqeRunDB qeCollectionDBRunnerqueueCollectionhandled dataField hostField versionField_id findAndModify mkEmittermkWorker getCursornextDoc$fExceptionMongoQueueException