我们有一个应用程序,它对hornetq
消息进行一些非常动态的路由,因此它可以在单个事务会话中从一个队列读取并写入另一个队列。这个想法是,如果我们不能移动到目标队列,我们就不会将其从原始队列中删除。它运行良好,直到我们对网络延迟进行一些测试——事情开始分崩离析。
由于延迟,事务处理无法提交,也无法回滚。我们看到数千条消息被困在deliverycount
中,即使在20分钟后也从未清除。默认情况下,连接工厂的调用超时为30秒。该应用程序有大约10个实例,为8个不同的目的地队列提供服务,因此您可能会认为,如果按顺序进行交付,我们不会看到超过80个文件滞留在deliveringcount
中,但我们确实看到了更多。
只有当应用程序关闭或我们终止并重新启动会话时,这些文件才能从deliveringCount
中取出。
看来HornetQ无法使事务超时(您可能会认为调用超时会起作用)并从deliveringcount
中删除这些文件。
有什么财产我们应该看看吗?我在寻找事务超时,但它只适用于我们不使用的XA事务。
顺便说一下,我们使用messagelistener
来接收消息。
以下是我们在回滚超时时遇到的错误(提交时也有类似的超时错误):
javax.jms.JMSException: HQ119014: Timed out waiting for response when sending packet 68
at org.hornetq.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:379)
at org.hornetq.core.client.impl.ClientSessionImpl.stop(ClientSessionImpl.java:726)
at org.hornetq.core.client.impl.ClientSessionImpl.stop(ClientSessionImpl.java:712)
at org.hornetq.core.client.impl.ClientSessionImpl.rollback(ClientSessionImpl.java:617)
at org.hornetq.core.client.impl.ClientSessionImpl.rollback(ClientSessionImpl.java:597)
at org.hornetq.core.client.impl.DelegatingSession.rollback(DelegatingSession.java:479)
at org.hornetq.jms.client.HornetQSession.rollback(HornetQSession.java:250)
at comms.HQRouter.MessageMover$MessageListenerImpl.onMessage(MessageMover.java:185)
at org.hornetq.jms.client.JMSMessageListenerWrapper.onMessage(JMSMessageListenerWrapper.java:98)
at org.hornetq.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1085)
at org.hornetq.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:57)
at org.hornetq.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1220)
at org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:106)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
Caused by: HornetQException[errorType=CONNECTION_TIMEDOUT message=HQ119014: Timed out waiting for response when sending packet 68]
... 16 more
HornetQ在2.3.0之后修复了一些错误。你应该试试它的最新版本。
我相信这个问题会在以后的版本中得到解决,但如果不是这样,你应该提供一个复制这个问题的测试并在论坛上发帖,或者如果你绝对确定你已经在最新版本的测试中复制了这个问题,你应该在JBoss JIRA上打开一个关于HornetQ项目的错误修复请求。