lib/amqp_source.js
function AmqpQueue(source) {
  assert.ok(source);
  TasksSource.Queue.apply(this, []);
  this.source = source;
  this._amqpProcessing = false;
}
function AmqpQueue(source) {
  assert.ok(source);
  TasksSource.Queue.apply(this, []);
  this.source = source;
  this._amqpProcessing = false;
}
function AmqpQueue ( source ) { assert . ok ( source ) ; TasksSource . Queue . apply ( this , [ ] ) ; this . source = source ; this . _amqpProcessing = false ; }
AMQP Queue Wrapper
AMQP Queue Wrapper