我有很简单的从HornetQ队列中读取MULE并将Object保存到数据库的设置:
设置如下:
<jms:connector name="connector.jms" maxRedelivery="1" connectionFactory-ref="hornetQConnectionFactory" doc:name="JMS"
createMultipleTransactedReceivers="true"
numberOfConcurrentTransactedReceivers="100"
acknowledgementMode="AUTO_ACKNOWLEDGE">
<reconnect count="50" frequency="5000"/>
</jms:connector>
<flow name="jmsListenerFlow1" doc:name="jmsListenerFlow1">
<jms:inbound-endpoint queue="adsLogQueue" connector-ref="connector.jms" doc:name="JMS">
<jms:transaction action="ALWAYS_BEGIN"/>
</jms:inbound-endpoint>
<component >
<spring-object bean="logSaver"/>
</component>
</flow>
Run Code Online (Sandbox Code Playgroud)
为什么在maxRedelivery设置为1时,我会在端点上收到消息已重新传送9次的消息?它究竟意味着什么?
hornetQConnectionFactory:
<bean name="hornetQTransportConfiguration" class="org.hornetq.api.core.TransportConfiguration">
<constructor-arg value="org.hornetq.core.remoting.impl.netty.NettyConnectorFactory"/>
<constructor-arg>
<map>
<entry key="host" value="${jms.host}" />
<entry key="port" value="${jms.port}" />
</map>
</constructor-arg>
</bean>
<bean name="hornetQConnectionFactory" class="org.hornetq.jms.client.HornetQJMSConnectionFactory">
<constructor-arg index="0" value="false"/>
<constructor-arg index="1" ref="hornetQTransportConfiguration"/>
<property name="minLargeMessageSize" value="250000"/>
<property name="cacheLargeMessagesClient" value="false"/>
</bean>
Run Code Online (Sandbox Code Playgroud)
任何帮助将不胜感激!
下面的堆栈跟踪.
ERROR 2012-10-19 01:04:07,283 [Thread-3013 (HornetQ-client-global-threads-1442093417)]: Message : "Message with id "ID:e6a0b303-1977-11e2-96d4-810571a3fe10" has …