在 Spring JMS 集成中配置基于间隔的 cron

Question

我需要在指定的时间间隔内将消息从 Queue1 转发到 Queue2，但不是在消息到达 Queue1 后才转发。下面是我的配置。

<int-jms:inbound-channel-adapter  id="inboundChannelAdapterId" connection-factory="connFactory" destination="jmsQueue1" channel="queueChannel" >
    <int:poller send-timeout="2000" >
        <!--
        <int:interval-trigger initial-delay="60000" interval="60000"
        fixed-rate="true"/>
        -->
        <int:cron-trigger expression="0 0/1 * * * ?" />
    </int:poller>
</int-jms:inbound-channel-adapter>

<int-jms:outbound-channel-adapter channel="queueChannel" connection-factory="connFactory" destination="jmsQueue2" >
</int-jms:outbound-channel-adapter>

<int:channel id="queueChannel" />

上面的 xml 配置立即将消息从 Queue1 转发到 Queue2，忽略。配置。我尝试过基于间隔和基于 cron 的解决方案，它们的工作原理似乎相似（立即将消息从 Queue1 传递到 Queue2）。这里的“poller”配置有什么问题吗？任何帮助将不胜感激。

Answer 1

您需要适配器上的接收超时。否则它将在 receive() 上阻塞并立即获取消息。

编辑：请参阅下面的注释 - 从 2.0.4 开始，默认情况下轮询队列的线程不再阻塞。

您可能还需要考虑为您的轮询器使用 2.0+ 语法；您当前的语法在 2.0 中已弃用，并且在 2.1 中不允许...

<jms:inbound-channel-adapter id="in" channel="jmsinToStdoutChannel" destination="requestQueue">
    <poller fixed-delay="30000"/>
</jms:inbound-channel-adapter>

只是为了澄清...如果在适配器上设置了接收超时，则轮询器线程将阻塞那么长时间或直到消息到达。这可能会让轮询器看起来没有遵守其时间表。默认值（自 2.0.4 起）是不阻塞，这意味着消息只会按照轮询器的时间表接收。