消费者 - 使用多个消者费者组订阅
创建客户端时,通过 nameAs 设定默认消费者组
//客户端
const client = await FolkMQ.createClient("folkmq://127.0.0.1:18602")
.nameAs("demoapp")
.connect();
1、使用默认消费者组
消费者组为 null 时,即使用默认的 client.name()
//订阅主题(使用默认消费者组)
client.subscribe("demo", null, true, message => {
//消费
console.log(message);
});
2、使用多个消费者组
//订阅主题,并指定加入的消费者分组
client.subscribe("demo", "demo-app1", true, message => {
//消费
console.log(message);
});
//订阅主题,并指定加入的消费者分组
client.subscribe("demo", "demo-app2", true, message => {
//消费
console.log(message);
});