testworker.js

var context = require('rabbit.js').createContext('amqp://localhost');
var async = require('async');

//var sub = context.socket('SUBSCRIBE', {noCreate: true});
var worker = context.socket('WORKER', {
  prefetch: 1
});
worker.setEncoding('utf8');
worker.connect('hello');



queue = async.queue(function(task, next) {
  var data;
  data = task.data;
  console.log(data);
  worker.ack();
  next();
}, 1);



worker.once('data', function(data) {

  console.log("Begin Bill read: " + new Date);
})



worker.on('data', function(data) {
  worker.pause();
  queue.push({
    data: data
  });
});

queue.drain = function() {
  worker.resume();
};

worker.on('end', function() {

  console.log("End Bill read: " + new Date);

});