此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.3.1! |
此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.3.1! |
到达通道适配器或网关的入站消息使用消息转换器转换为有效负载。
默认情况下,使用 a,它处理 java 序列化和文本。
默认情况下,标头使用 映射。
如果发生转换错误,并且未定义错误通道,则异常将抛向容器,并由侦听器容器的错误处理程序处理。
默认错误处理程序将转换错误视为致命错误,并且邮件将被拒绝(如果队列是这样配置的,则将邮件路由到死信交换)。
如果定义了错误通道,则有效负载是具有属性(无法转换的 Spring AMQP 消息)和 .
如果容器是(默认值),并且错误流在不引发异常的情况下使用错误,则将确认原始消息。
如果错误流引发异常,则异常类型与容器的错误处理程序一起确定消息是否重新排队。
如果容器配置了 ,则有效负载是具有附加属性和 的 。
这使错误流能够调用消息或(或)来控制其处置。spring-messaging
Message<?>
SimpleMessageConverter
DefaultHeaderMapper.inboundMapper()
ErrorMessage
ListenerExecutionFailedException
failedMessage
cause
AcknowledgeMode
AUTO
AcknowledgeMode.MANUAL
ManualAckListenerExecutionFailedException
channel
deliveryTag
basicAck
basicNack
basicReject