在apache nms中输入消息

Question

我正在尝试使用apache执行发送/接收消息。由于使用hornetq，我不能使用跨国攻击模式。我的消费者场景：

1. 收到一条消息
2. 处理消息
3. 如果进程成功(使用message.Acknowledge())，将其保存下来
4. 如果进程失败(？)

如果进程失败，我所需要的就是NACK消息；那么，我如何在apache中添加消息呢？

Answer 1

我不知道为什么您不能使用HornetQ的事务。当前让客户端发送NACK的唯一方法是使用事务并在出错时回滚事务。一旦您到达已配置的Max允许的重发，客户端将锁定消息。

在大多数实现中，如果客户端没有ACK，那么消息就会被重新传递到另一个客户端。在ActiveMQ的情况下，您可以配置代理在将消息移动到死信队列之前尝试的最大次数。

现在，当从异步消息回调抛出异常时，NMS.Stomp实现不会破坏消息--但是这可能是一个明智的增强，项目确实接受贡献，因此投入其中。