|
对于最新的稳定版本，请使用 spring-cloud-stream 4.3.0！ |
错误通道
从 1.3 版开始，绑定器无条件地将异常发送到每个使用者目标的错误通道，也可以配置为将异步生产者发送失败发送到错误通道。 有关详细信息，请参阅“错误处理”。
RabbitMQ 有两种类型的发送失败：
-
返回的消息，
-
负面确认的出版商确认。
后者很少见。
根据 RabbitMQ 文档，“只有当负责队列的 Erlang 进程中发生内部错误时，才会传递 [a nack]。
如果将reject-publish队列溢出行为。
除了启用生产者错误通道（如“错误处理”中所述）外，RabbitMQ 绑定器仅在连接工厂配置正确的情况下向通道发送消息，如下所示：
-
ccf.setPublisherConfirms(true); -
ccf.setPublisherReturns(true);
对连接工厂使用 Spring Boot 配置时，请设置以下属性：
-
spring.rabbitmq.publisher-confirms -
spring.rabbitmq.publisher-returns
的有效负载ErrorMessage对于返回的消息，是ReturnedAmqpMessageException具有以下属性：
-
failedMessage：春季消息Message<?>未能发送。 -
amqpMessage：原始 spring-amqpMessage. -
replyCode：指示失败原因的整数值（例如，312 - 无路由）。 -
replyText：指示失败原因的文本值（例如，NO_ROUTE). -
exchange：将消息发布到的交换。 -
routingKey：发布邮件时使用的路由密钥。
另请参阅发布者确认，了解接收返回消息的替代机制。
对于否定确认，有效负载是NackedAmqpMessageException具有以下属性：
-
failedMessage：春季消息Message<?>未能发送。 -
nackReason：原因（如果可用 - 您可能需要检查代理日志以获取更多信息）。
不会自动处理这些异常（例如发送到死信队列）。 您可以在自己的 Spring Integration 流中使用这些异常。