lib/amqp/exchange.js
function define() {
    let libOptions = getLibOptions({
      alternate: 'alternateExchange'
    }, ['persistent', 'publishTimeout']);
    topLog.debug(`Declaring ${options.type} exchange \'${options.name}\' on connection \'${connectionName}\' with the options: ${JSON.stringify(_.omit(libOptions, ['name', 'type']))}`);
    return channel.assertExchange(options.name, options.type, libOptions);
  }
function define() {
    let libOptions = getLibOptions({
      alternate: 'alternateExchange'
    }, ['persistent', 'publishTimeout']);
    topLog.debug(`Declaring ${options.type} exchange \'${options.name}\' on connection \'${connectionName}\' with the options: ${JSON.stringify(_.omit(libOptions, ['name', 'type']))}`);
    return channel.assertExchange(options.name, options.type, libOptions);
  }
function define ( ) { let libOptions = getLibOptions ( { alternate : 'alternateExchange' } , [ 'persistent' , 'publishTimeout' ] ) ; topLog . debug ( ` ${ options . type } \' ${ options . name } \' \' ${ connectionName } \' ${ JSON . stringify ( _ . omit ( libOptions , [ 'name' , 'type' ] ) ) } ` ) ; return channel . assertExchange ( options . name , options . type , libOptions ) ; }
Define the exchange
@public
Define the exchange