const { publisher } = require('np-q-producer')

let config = {
  exchange: 'night',
  queue: {
    connection: 'amqp://admin:[email protected]:5672',
    channel: 'ZOO_QUEUE',
    consumerAdapters: [{
      queueName: 'task'
    }, {
      queueName: 'new'
    }]
  }
}

publisher.start(config,(err) => {
    console.log('publish start')
})

const { publisher } = require('np-q-producer')

publisher.publish({a:1}, 'task', function (err) {
    console.log('publish success')
})

const { consumer } = require('np-q-producer')

let config = {
  exchange: 'night',
  queue: {
    connection: 'amqp://admin:[email protected]:5672',
    channel: 'ZOO_QUEUE',
    consumerAdapters: [{
      queueName: 'task'
    }, {
      queueName: 'new'
    }]
  }
}

consumer.start(config,(err,message) => {
    console.log('Consumer started.',message)
})

npm run standard