lib/amqp.js
function createChannel(addr) {
  return amqp.connect(genAddr(addr)).then(conn => {
    return conn.createChannel().then(ch => {
      connections.push(conn);

      return [conn, ch];
    });
  }, debugError);
}
function createChannel(addr) {
  return amqp.connect(genAddr(addr)).then(conn => {
    return conn.createChannel().then(ch => {
      connections.push(conn);

      return [conn, ch];
    });
  }, debugError);
}
function createChannel ( addr ) { return amqp . connect ( genAddr ( addr ) ) . then ( conn => { return conn . createChannel ( ) . then ( ch => { connections . push ( conn ) ; return [ conn , ch ] ; } ) ; } , debugError ) ; }
create channel helper
create channel helper