import { Producer } from 'rocketmq-client-nodejs';

const producer = new Producer({
  endpoints: 'rmq-xxx.rocketmq.gz.qcloud.tencenttdmq.com:8080', // Tencent Cloud access point.
  sessionCredentials: {
    accessKey: 'yourAccessKey', // ak
    accessSecret: 'yourSecretKey', // sk
  }
});
await producer.startup();

const receipt = await producer.send({
  topic: 'TopicTest', // Topic created in the console.
  body: Buffer.from(JSON.stringify({
    hello: 'rocketmq-client-nodejs world',
    now: Date(),
  })),
});
console.log(receipt);

import {SimpleConsumer } from 'rocketmq-client-nodejs';
const simpleConsumer = new SimpleConsumer({
    endpoints: 'rmq-xxx.rocketmq.gz.qcloud.tencenttdmq.com:8080', // Tencent Cloud access point.
  sessionCredentials: {
    accessKey: 'yourAccessKey', // ak
    accessSecret: 'yourSecretKey', // sk
  },
  consumerGroup: 'nodejs-demo-group', // Consumer group.
  subscriptions: new Map().set('TopicTest', '*'),
});
await simpleConsumer.startup();

const messages = await simpleConsumer.receive(20);
console.log('got %d messages', messages.length);
for (const message of messages) {
  console.log(message);
  console.log('body=%o', message.body.toString());
  await simpleConsumer.ack(message);
}