FolkMQ v1.7.8

消费者 - 使用多个消者费者组订阅

创建客户端时,通过 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);
});