docs: function AmqpTasksSource(amqpOptions) {
    TasksSource.apply(this, arguments);
    assert.ok(amqpOptions, "amqpOptions are required in order to create a AmqpTasksSource");
    Object.defineProperty(this, 'amqpOptions', {
      value: amqpOptions,
      enumerable: false,
      configurable: false
    });
    this.connection = null;
    this._amqpExchange = null;
    this.exchangeName = 'orch';
    this._queues = {};
  }