Spring集成org.springframework.integration.MessageTimeoutException处理

Question

我有以下 spring 集成流程：

        @Bean
        public IntegrationFlow innerInFlow(@Value("${jms.concurrency:10}") String concurrency) {
            return IntegrationFlows
                    .from(Jms.messageDrivenChannelAdapter(
                            Jms.container(connectionFactory, innerQueue)
                                    .concurrency(concurrency)
                                    .taskExecutor(taskExecutor()).get())
                            .extractPayload(true))
                    .transform(Transformers.deserializer())
                    .route(eventRouter())
                    .get();
        }

路由之后

        @Bean
        public IntegrationFlow findPersonClienFlow(FindClientHandler findClientHandler) {
            return IntegrationFlows.from(findPersonClienChannel())
                    .transform(findClientHandler, "queryToFindClientRequest")
                    .handle(Jms.outboundGateway(connectionFactory).requestDestination(cifRequestQueue)
                            .replyDestination(cifResponseQueue).get())
                    .get();
        }

    }

在Jms.outboundGateway 中我有org.springframework.integration.MessageTimeoutException，但我无法理解如何处理此错误？

谢谢。

Answer 1

我相信MessageTimeoutException 存在是因为对方没有回复你到cifResponseQueue。

您可以在那里配置receiveTimeout()，但无论如何默认为5 secs。

您还可以在此Jms.outboundGateway() 上配置RequestHandlerRetryAdvice 或ExpressionEvaluatingRequestHandlerAdvice，以使用ConsumerEndpointSpec 的advice(...) 以某种特定方式真正处理此异常。

请参阅有关此事的文档：https://docs.spring.io/spring-integration/docs/current/reference/html/messaging-endpoints-chapter.html#message-handler-advice-chain

更新

此外，正如 Gary 指出的，您可以使用 Jms.messageDrivenChannelAdapter() 级别的 errorChannel() 和订阅此频道的一些流来捕获异常。