ali-ons
Aliyun Open Notification Service Client (base on opensource project RocketMQ)
Sub module of ali-sdk.
Install
npm install ali-ons --save
Usage
consumer
'use strict'; const httpclient = ;const Consumer = Consumer;const consumer = httpclient accessKey: 'your-accesskey' secretKey: 'your-secretkey' consumerGroup: 'your-consumer-group' // isBroadcast: true,; consumer; consumer;
producer
'use strict'; const co = ;const httpclient = ;const Producer = Producer;const Message = Message; const producer = httpclient accessKey: 'your-accesskey' secretKey: 'your-secretkey' producerGroup: 'your-producer-group'; producer;
Rocketmq
implemention from yeliex/rocketmq
consumer
const 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.;
producer
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
});