2016-01-22 45 views
0

我有一个运行在Wildfly 9.0.1上的AcitveMQ 5.13的spring集成(4.1.6)应用程序。我只用了大约11个队列。ActiveMQ队列不从Spring集成应用程序消耗

我有一个队列卡住了,消息没有被消耗(大部分)。我的其他每个队列都按照计划与入站通道适配器上的轮询器一起正常使用。

我现在的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),将在队列导致消息被消耗,大多数的时间。有时候,只是反弹蜻蜓会触发消息消费。有时,如果我让它坐下来,消息就会消耗殆尽。这些消息是简单的XML。

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

任何人都可以看到任何错误或有任何人遇到并解决了类似的东西吗?

回答

1

最常见的原因是挂起轮询器线程(卡在用户代码中)。即gnfChannelIn下游的东西挂在线程上。

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

相关问题