deepexi-rocketmq

2.0.1 • Public • Published

rocketmq

NPM version build status David deps node version

Rocket MQ SDK support Aliyun Open Notification Service Client (base on opensource project RocketMQ)

Forked from rocketmq

主要是更改了日志等级

Install

npm install rocketmq --save

Usage

consumer

'use strict';
 
const Consumer = require('rocketmq').Consumer;
const consumer = new Consumer({
  namesrvAddr: 'localhost:9876', // for rocket mq
  accessKey: 'your-accesskey',  // for aliyun-ons
  secretKey: 'your-secretkey',  // for aliyun-ons
  onsAddr: '',                   // for aliyun-ons
  consumerGroup: 'your-consumer-group',  // for aliyun-ons
  
  isBroadcast: false, // default is false, that mean messages will be pushed to consumer cluster only once.
});
 
consumer.subscribe(config.topic, '*', function*(msg) {
  console.log(`receive message, msgId: ${msg.msgId}, body: ${msg.body.toString()}`)
});
 
consumer.on('error', err => console.log(err));

producer

'use strict';
 
const Producer = require('rocketmq').Producer;
const Message = require('rocketmq').Message;
 
const producer = new Producer({
  namesrvAddr: 'localhost:9876', // for rocket mq
  accessKey: 'your-accesskey',   // for aliyun-ons
  secretKey: 'your-secretkey',    // for aliyun-ons
  producerGroup: 'your-producer-group',  // for aliyun-ons
});
 
producer.ready(() => {
  console.log('producer ready');
  const msg = new Message('your-topic', // topic
    'TagA', // tag
    'Hello ONS !!! ' // body
  );
 
  producer.send(msg, (err, sendResult) => console.log(err, sendResult));
});

License

MIT

Package Sidebar

Install

npm i deepexi-rocketmq

Weekly Downloads

0

Version

2.0.1

License

MIT

Unpacked Size

139 kB

Total Files

40

Last publish

Collaborators

  • donhac