【发布时间】:2020-05-08 06:56:14
【问题描述】:
CachingConnectionFactory 确认类型简单与相关之间有什么区别。
【问题讨论】:
标签: spring-boot rabbitmq spring-amqp spring-rabbit
CachingConnectionFactory 确认类型简单与相关之间有什么区别。
【问题讨论】:
标签: spring-boot rabbitmq spring-amqp spring-rabbit
correlated 表示你在发送时传入了一些相关数据,收到确认后你会收到回调;回调获取相关数据 - 所以您知道确认是针对哪个发送的。您可以等待相关数据中的Future<?>,如果它被返回,它也可以包含返回的消息。
使用simple,这只是意味着您可以阻止等待确认您发送的所有消息已收到(waitForConfirmsOrDie)。通过简单的确认没有提供相关性。
https://docs.spring.io/spring-amqp/docs/2.2.6.RELEASE/reference/html/#template-confirms
和
https://docs.spring.io/spring-amqp/docs/2.2.6.RELEASE/reference/html/#scoped-operations
【讨论】:
waitForConfirmsOrDie 会阻塞直到它们到达(或超时)。
Channel (amqp-client) 的 javadocs。如果所有 ack 都是好的,则返回 true,如果任何 ack 不好,则抛出异常。