code: function CreateAmqp(provider, url, options) {
    var self = this;
    options = url ? {url: url} : options;
    amqp.Connection.call(self, options, {reconnect: false});
  
    self.provider = provider;
  
    // slmq private extensions to node-amqp connection
    self._slmq = {
      whenReady: jobs.delayed(),  // delayed until connection ready
    };
  
    self.once('ready', function() {
      dbg('task-start');
      self._slmq.whenReady.start();
    });
  }
docs: -- Connection