如果成功交付到队列，则 Spring Integration DSL 回复成功答案

【问题标题】：Spring Integration DSL reply success if successful delivery to queue如果成功交付到队列，则 Spring Integration DSL 回复成功
【发布时间】：2020-01-27 17:27:42
【问题描述】：

我正在尝试公开 HTTP 端点，该端点将向 JMS 队列发送一条消息，如果传递成功，我想回复 Success，如果无法传递消息，则回复 FAILURE。

 @Bean
    public IntegrationFlow systemTaskCall(MapToServiceTaskConfigTransformer mapTransformer, CachingConnectionFactory jmsConnectionFactory) {
        return IntegrationFlows.from(
                Http.inboundGateway("/spartaSystemTask")
                        .requestMapping(r -> r
                                .methods(HttpMethod.POST)
                                .consumes("application/json")
                        )
                        .requestPayloadType(Map.class)
                        .replyChannel(RESPONSE_CHANNEL)
                        .errorChannel("errorChannel")
        )
                .handle((payload, headers) -> mapTransformer.transform((Map<String, String>) payload))
                .enrichHeaders(Collections.singletonMap(DESTINATION_QUEUE, "request.queue"))
                .enrichHeaders(Collections.singletonMap(JMS_REPLY_TO, "response.queue"))
                .transform(Transformers.toJson())
                .handle(
                        Jms.outboundGateway(jmsConnectionFactory,)
                            .requestDestination(message -> message.getHeaders().get(DESTINATION_QUEUE))

                )
                .log(LoggingHandler.Level.ERROR)
                .enrichHeaders(
                        c -> c.header(org.springframework.integration.http.HttpHeaders.STATUS_CODE, HttpStatus.CREATED)
                )
                .transform(source -> "SUCCESS")
                .transform(Transformers.toJson())
                .channel(RESPONSE_CHANNEL)
                .get();
    }

 @Bean
    public IntegrationFlow errorFlow(){
        return IntegrationFlows.from("errorChannel")
                .transform(source -> "error")
                .transform(Transformers.toJson())
                .channel(RESPONSE_CHANNEL)
                .get();
    }

当我调用此 URL 时，消息被丢弃但 HTTP 调用超时。似乎发布了 JMS 出站网关调用，其余代码未执行。

如果消息传递失败，我会得到正确的响应。

【问题讨论】：

标签： spring spring-integration spring-integration-dsl

【解决方案1】：

你有这个配置：

.handle(
                    Jms.outboundGateway(jmsConnectionFactory,)
                        .requestDestination(message -> message.getHeaders().get(DESTINATION_QUEUE))

            )

outboundGateway。这意味着您发送一个请求并期望来自另一方的响应，但看起来您只将一条 JMS 消息发送到一个队列中，而另一方的侦听器没有人用 response.queue 中的某些内容来回答您。这就是正常 JMS 发布超时的原因。

您需要确保您的流程中的逻辑是正确的，并且在您期望来自服务器端的一些回复的分布式解决方案中确实有效。

否则，您需要考虑将您的逻辑更改为Jms.outboundAdapter()，这确实是单向发送者。对于 HTTP 回复，您可以使用 publishSubscribeChannel() 并将此 Jms.outboundAdapter() 作为第一个订阅者，将流程的其余部分作为第二个订阅者。这样，在第一个订阅者正确完成其逻辑之前，不会调用第二个订阅者。对于错误情况，您可以用ExpressionEvaluatingRequestHandlerAdvice 包装Jms.outboundAdapter()：https://docs.spring.io/spring-integration/docs/5.2.3.RELEASE/reference/html/messaging-endpoints.html#message-handler-advice-chain

【讨论】：