0

我有一个在 Wildfly 9.0.1 和 AcitveMQ 5.13 上运行的 spring 集成 (4.1.6) 应用程序。我只使用了大约 11 个队列。

我有一个队列卡住了，消息没有被消耗（大部分）。我使用入站通道适配器上的轮询器按计划正常消耗了所有其他队列。

我当前的 Spring Integration 配置如下所示：

<beans:bean id="gnfReportConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <beans:property name="targetConnectionFactory">
        <beans:bean class="org.apache.activemq.ActiveMQConnectionFactory" >
            <beans:property name="brokerURL" value="${activemq.broker.url}" />
            <beans:property name="checkForDuplicates" value="false" />
        </beans:bean>
    </beans:property>
    <beans:property name="sessionCacheSize" value="100" />
    <beans:property name="cacheProducers" value="true" />
    <beans:property name="cacheConsumers" value="true" />
    <beans:property name="reconnectOnException" value="true" />
</beans:bean>

<!-- Email Router -->
<channel id="gnfChannelIn" />
<channel id="gnfChannelOut" />

<beans:bean id="gnfReportQueue" class="org.apache.activemq.command.ActiveMQQueue">
    <beans:constructor-arg value="${gnf.report.queue}" name="name" />
</beans:bean>

<int-jms:inbound-channel-adapter id="gnfReportChannelAdapter" connection-factory="gnfReportConnectionFactory" destination="gnfReportQueue" channel="gnfChannelIn" auto-startup="true">
    <poller fixed-delay="60" time-unit="SECONDS" max-messages-per-poll="-1" receive-timeout="10000" />
</int-jms:inbound-channel-adapter>

有趣的事情之一是，当我反弹所有会导致队列中的消息被消耗的东西（ActiveMQ 和 Wildfly）时，大部分时间。有时，只是弹跳 Wildfly 就会触发消息消费。有时，如果我让它坐下来，消息就会被消耗掉。消息是简单的 XML。

我正在使用的其他队列都以相同的方式配置。

任何人都可以看到任何问题，或者有人遇到并解决了类似的问题吗？

4

1 回答 1

1

最常见的原因是轮询线程挂起（卡在用户代码中）。即下游的东西gnfChannelIn正在挂起线程。

使用 jstack 或 jvisualvm/jconsole 获取线程转储以查看线程在做什么。

于 2016-01-22T20:51:56.133 回答