1

我正在使用带有 RabbitMQ 的发布者确认。我想测试我的代码,我正在处理未确认的消息(handleNack 方法)。如何创建场景以从代理接收 Nacks?停止代理或将消息发布到已达到其限制的队列,根本没有帮助。

提前致谢..

ch.setConfirmListener(new ConfirmListener() {
    public void handleAck(long seqNo, boolean multiple) {
        if (multiple) {
            unconfirmedSet.headSet(seqNo+1).clear();
        } else {
            unconfirmedSet.remove(seqNo);
        }
    }
    public void handleNack(long seqNo, boolean multiple) {
        // handle the lost messages somehow
    }
}
4

0 回答 0