Spring 集成 Jms.outboundGateway x 防火墙

Question

当网络防火墙打开时，以下流程可以正常工作，但是如果我们关闭它并且无法访问 JMS 代理，则根本不会发生超时并且调用者进程会卡住。网关计时器似乎没有启动，因为线程没有返回......你能建议处理这种不愉快情况的最佳方法是什么吗？

@Bean
public IntegrationFlow request() {
  return IntegrationFlows.from(requestChannel)
                               .handle(Jms.outboundGateway(this.connectionFactyory)
                               .requestDestination(requestQueue)
                               .extractReplyPayload(false)
                               .correlationKey("JMSCorrelationID")
                               .receiveTimeout(5000L))
                               .channel(replyChannel).get();
}

Answer 1

见receiveTimeoutJavaDocs：

/**
 * Set the max timeout value for the MessageConsumer's receive call when
 * waiting for a reply. The default value is 5 seconds.
 * @param receiveTimeout The receive timeout.
 */
public void setReceiveTimeout(long receiveTimeout) {

所以，它实际上是关于一个 reply，当我们已经发送了一个 request 时会触发它。更重要的是，您肯定会使用默认的 5 秒作为其值。所以，阻塞问题在其他地方。

如果您与我们分享org.springframework.integration 的一些 DEBUG（甚至是 TRACE）日志，以了解在没有 JMS 代理访问权限的情况下向流发送消息时发生了什么，那就太好了。