消费者 - 订阅

1、订阅主题，并自动 ACK

订阅接口的参数，依次为：主题，消费处理。

//客户端
const client = await FolkMQ.createClient("folkmq://127.0.0.1:18602")
        .nameAs("demoapp")
        .connect();

//订阅主题，并指定加入的消费者分组
client.subscribe("demo", null, true, message => {
    //消费
    System.out.println(message);
});

2、订阅主题，并手动 ACK

手动 ACK 适合异步消费，或者控制性强的场景。

//客户端
const client = await FolkMQ.createClient("folkmq://127.0.0.1:18602")
        .nameAs("demoapp")
        .connect();

//订阅主题，并指定加入的消费者分组
client.subscribe("demo", null, false, message => {
    //消费
    System.out.println(message);

    //手动 ACK
    message.acknowledge(true);
});

3、取消订阅

取消订阅接口有两个参数，依次为：主题，消费者分组。

//取消订阅
client.unsubscribe("demo", null);