rocketmq
v2.0.1
Published
Rocket MQ SDK support Aliyun Open Notification Service Client
Downloads
21
Maintainers
Readme
rocketmq
Rocket MQ SDK support Aliyun Open Notification Service Client (base on opensource project RocketMQ)
Forked from ali-ons
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));
});