np-q-producer

=========================

np-q-producer queue service

Install

$ npm install --save np-q-producer

or

$ yarn add  np-q-producer

Usage

startup

you need add this to startup file

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

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

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

publisher

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

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

consumer

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

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

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

Example

Example

JavaScript Style

npm run standard

Contributors

阿文 @kelvv
老魏 @qknow
徐晨 @shadow88sky
文卿 @Wenqing Yu  
业生 @CNBlackJ