RocketMQ-Nodejs-client
RocketMq Open Notification Service Client (base on opensource project RocketMQ)
Sub module of ali-sdk.
Install
npm install ax-rocketmq --save
Usage
consumer
'use strict'; const httpclient = ;const Consumer = Consumer;const consumer = httpclient consumerGroup: 'your-consumer-group' namesrvAddr: 'your-namesrv-address' // isBroadcast: true,; consumer; consumer;
producer
'use strict'; const httpclient = ;const Producer = Producer;const Message = Message; const producer = httpclient producerGroup: 'your-producer-group' namesrvAddr: 'your-namesrv-address'; producer;