3 Replies Latest reply on Nov 25, 2009 11:17 AM by andreyy

    Exceptions when publishing on clustered topics

      Hi, all,
      I'm using Hornetq in a clustered configuration with 5 AMD 64 bit quad core machines running Centos and Java 6. I'm trying to post status information out from one machine to subscribers on the others on a topic. It generally works pretty well, but I often get exceptions like the following:

      Is this a network issue? Any suggestions for where I could look? Prayers?

      Thanks for your advice.

      2009-11-23 02:23:18,468 INFO [org.hornetq.core.server.cluster.impl.BridgeImpl] (Thread-7) Stopped bridge sf.odi-cluster.89c806a8-d3cc-11de-ada8-000e1e0044ac
      2009-11-23 02:23:18,480 WARNING [org.hornetq.core.server.impl.QueueImpl] (Thread-661 (group:HornetQ-server-threads26433900-13887543)) removing consumer which did not handle a message, consumer=org.hornetq.core.server.cluster.impl.BridgeImpl@13455ea, message=Reference[32217838426]:RELIABLE java.lang.NullPointerException
      2009-11-23 02:24:13,479 INFO [org.hornetq.core.server.cluster.impl.BridgeImpl] (Thread-7) Stopping bridge sf.odi-cluster.89c806a8-d3cc-11de-ada8-000e1e0044ac
      2009-11-23 02:24:13,482 SEVERE [org.hornetq.core.server.cluster.impl.BridgeImpl] (New I/O client worker #344-1) Failed to ack
      java.lang.IllegalStateException: Cannot find add info 32217838426
      at org.hornetq.core.journal.impl.JournalImpl.appendUpdateRecord(JournalImpl.java:886)
      at org.hornetq.core.persistence.impl.journal.JournalStorageManager.storeAcknowledge(JournalStorageManager.java:302)
      at org.hornetq.core.server.impl.QueueImpl.acknowledge(QueueImpl.java:673)
      at org.hornetq.core.server.cluster.impl.BridgeImpl.sendAcknowledged(BridgeImpl.java:380)
      at org.hornetq.core.client.impl.ClientSessionImpl.commandConfirmed(ClientSessionImpl.java:815)
      at org.hornetq.core.remoting.impl.ChannelImpl.clearUpTo(ChannelImpl.java:741)
      at org.hornetq.core.remoting.impl.ChannelImpl.handlePacket(ChannelImpl.java:569)
      at org.hornetq.core.remoting.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:397)
      at org.hornetq.core.remoting.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:349)
      at org.hornetq.core.client.impl.ConnectionManagerImpl$DelegatingBufferHandler.bufferReceived(ConnectionManagerImpl.java:1142)
      at org.hornetq.integration.transports.netty.HornetQChannelHandler.messageReceived(HornetQChannelHandler.java:64)
      at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:105)
      at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:567)
      at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:803)
      at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:385)
      at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:324)
      at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:306)
      at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:223)
      at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:87)
      at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:567)
      at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:562)
      at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:342)
      at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:329)
      at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:330)
      at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:282)
      at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:203)
      at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:113)
      at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:53)
      at org.hornetq.integration.transports.netty.VirtualExecutorService$ChildExecutorRunnable.run(VirtualExecutorService.java:174)
      at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)
      at java.lang.Thread.run(Thread.java:619)
      2009-11-23 02:24:13,485 INFO [org.hornetq.core.server.cluster.impl.BridgeImpl] (Thread-7) Stopped bridge sf.odi-cluster.89c806a8-d3cc-11de-ada8-000e1e0044ac