使用rabbitmq客户端Java API保证交付

Question

我想知道处理通信错误（rabbitmq崩溃或网络问题）的最佳方式是什么，例如使用java API。

我们使用Channel.basicPublish（...）方法，并且我们希望为发送给经纪人的每条消息提供保证金交付服务 。

更具体地讲，是有在java客户端mecanism发布 API（发送到总线的消息之前），从而确保了该 消息将交付（或回调调用的时候，总线发送 IOException），还是我们必须实现这个过程？

你会怎么做？

---

从西门MacMullen RabbitMQ的名单上的反应： “ 目前可以保证一个发布已经通过是一个事务内发布的唯一办法 - 当事务提交完成的消息是上磁盘（假设持久的队列/持久性消息），这是一个小的重量级不过，在未来我们打算引入流媒体出版商的ACK做同样的工作，更异步的方式。

干杯，西蒙 “

Answer 1

在RabbitMQ中e是一个方法channel.basicAck（），它会让你确认消息。