Queue Samples

Scenario: Read messages from stdin and put them on a queue. Check queue every second; if a message is found, print it to stdout and delete it.

var storage = require('bluesky').storage();

var queue = storage.queue('test');

queue.on('message', function(m, done) {
  console.log('>> ' + m);
  done();
});

queue.poll(1000);

process.stdin.resume();

process.stdin.on('data', function (chunk) {
  queue.put(chunk);
});