Uses capped collection, tailable cursors and streams.
- init.js recreates collection capped collection 'queue' on mongodb.
- writer.js spams queue with new messages
- worker.js processes all messages saved to queue,
- onceWorker.js processes only unprocessed messages, so you can spawn several of them and each of your messages will be processed by only one worker.