'use strict';
 
const httpclient = require('urllib');
const Consumer = require('ax-rocketmq').Consumer;
const consumer = new Consumer({
  httpclient,
  consumerGroup: 'your-consumer-group',
  namesrvAddr: 'your-namesrv-address'
  // isBroadcast: true,
});
 
consumer.subscribe(config.topic, '*', async msg => {
  console.log(`receive message, msgId: ${msg.msgId}, body: ${msg.body.toString()}`)
});
 
consumer.on('error', err => console.log(err));

'use strict';
 
const httpclient = require('urllib');
const Producer = require('ax-rocketmq').Producer;
const Message = require('ax-rocketmq').Message;
 
const producer = new Producer({
  httpclient,
  producerGroup: 'your-producer-group',
  namesrvAddr: 'your-namesrv-address'
});
 
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));
});