我正在使用带有 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
}
}