lib/amqp/queue.js
function define() {
    let aqOptions = getAssertQueueOptions();
    topLog.info(`Declaring queue \'${channelName}\' on connection \'${connectionName}\' with the options: ${JSON.stringify(_.omit(aqOptions, ['name']))}`);
    return channel.assertQueue(channelName, aqOptions);
  }
function define() {
    let aqOptions = getAssertQueueOptions();
    topLog.info(`Declaring queue \'${channelName}\' on connection \'${connectionName}\' with the options: ${JSON.stringify(_.omit(aqOptions, ['name']))}`);
    return channel.assertQueue(channelName, aqOptions);
  }
function define ( ) { let aqOptions = getAssertQueueOptions ( ) ; topLog . info ( ` \' ${ channelName } \' \' ${ connectionName } \' ${ JSON . stringify ( _ . omit ( aqOptions , [ 'name' ] ) ) } ` ) ; return channel . assertQueue ( channelName , aqOptions ) ; }
Define the queue
@public
Define the queue