HQ224051: Failed to call notification listener: java.lang.IllegalStateException: Cannot find queue info for queue ...
stelian.galmati Apr 15, 2015 6:46 AMHi,
I've tried configuring hornetq cluster embeded in wildfly 8.0. The version of hornetq was updated to 2.4.5 (the jboss wasn't). The configuration is using static connectors and everything seems to be working since I get the following:
INFO [org.hornetq.core.server] (Thread-22 (HornetQ-server-HornetQServerImpl::serverUUID=5a44f206-e33f-11e4-bead-51bf9af92ddd-357074323)) HQ221027: Bridge ClusterConnectionBridge@3e12db52 [name=sf.my-cluster.bf672050-e2a7-11e4-b424-d57a98e7a2b7, queue=QueueImpl[name=sf.my-cluster.bf672050-e2a7-11e4-b424-d57a98e7a2b7, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=5a44f206-e33f-11e4-bead-51bf9af92ddd]]@64a0d641 targetConnector=ServerLocatorImpl (identity=(Cluster-connection-bridge::ClusterConnectionBridge@3e12db52 [name=sf.my-cluster.bf672050-e2a7-11e4-b424-d57a98e7a2b7, queue=QueueImpl[name=sf.my-cluster.bf672050-e2a7-11e4-b424-d57a98e7a2b7, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=5a44f206-e33f-11e4-bead-51bf9af92ddd]]@64a0d641 targetConnector=ServerLocatorImpl [initialConnectors=[TransportConfiguration(name=netty, factory=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory) ?port=5445&host=0-0-0-0], discoveryGroupConfiguration=null]]::ClusterConnectionImpl@1421158568[nodeUUID=5a44f206-e33f-11e4-bead-51bf9af92ddd, connector=TransportConfiguration(name=netty, factory=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory) ?port=5445&host=ffm04apppto01m, address=jms, server=HornetQServerImpl::serverUUID=5a44f206-e33f-11e4-bead-51bf9af92ddd])) [initialConnectors=[TransportConfiguration(name=netty, factory=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory) ?port=5445&host=0-0-0-0], discoveryGroupConfiguration=null]] is connected
The strange part is that after I stop node1 I get the following errors on node2 and after I start node1 (node2 is still up) I get the same errors on it also:
ERROR [org.hornetq.core.server] (Thread-32 (HornetQ-client-global-threads-1332602561)) HQ224037: cluster connection Failed to handle message: java.lang.IllegalStateException: Cannot find binding for jms.queue.featureProcessingQueue5a44f206-e33f-11e4-bead-51bf9af92ddd on ClusterConnectionImpl@1421158568[nodeUUID=5a44f206-e33f-11e4-bead-51bf9af92ddd, connector=TransportConfiguration(name=netty, factory=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory) ?port=5445&host=ffm04apppto01m, address=jms, server=HornetQServerImpl::serverUUID=5a44f206-e33f-11e4-bead-51bf9af92ddd] at org.hornetq.core.server.cluster.impl.ClusterConnectionImpl$MessageFlowRecordImpl.doConsumerCreated(ClusterConnectionImpl.java:1426) [hornetq-server-2.4.5.Final.jar:]
ERROR [org.hornetq.core.server] (Thread-5 (hornetq-netty-threads-715500486)) HQ224051: Failed to call notification listener: java.lang.IllegalStateException: Cannot find queue info for queue jms.queue.featureProcessingQueue5a44f206-e33f-11e4-bead-51bf9af92ddd at org.hornetq.core.postoffice.impl.PostOfficeImpl.onNotification(PostOfficeImpl.java:314) [hornetq-server-2.4.5.Final.jar:] at org.hornetq.core.server.management.impl.ManagementServiceImpl.sendNotification(ManagementServiceImpl.java:682) [hornetq-server-2.4.5.Final.jar:]
Also, on the node1 which I am stopping, just before shutdown, the following is logged:
2015-04-15 09:29:02,318 INFO [org.hornetq.core.server] (Thread-14 (HornetQ-server-HornetQServerImpl::serverUUID=bf672050-e2a7-11e4-b424-d57a98e7a2b7-80392215)) HQ221029: stopped bridge sf.my-cluster.5a44f206-e33f-11e4-bead-51bf9af92ddd 2015-04-15 09:29:02,322 WARN [org.hornetq.core.client] (Thread-28 (HornetQ-client-global-threads-834094040)) HQ212037: Connection failure has been detected: HQ119015: The connection was disconnected because of server shutdown [code=DISCONNECTED] 2015-04-15 09:29:02,340 WARN [org.hornetq.core.client] (Thread-28 (HornetQ-client-global-threads-834094040)) HQ212028: error starting server locator: HornetQIllegalStateException[errorType=ILLEGAL_STATE message=null] at org.hornetq.core.client.impl.ServerLocatorImpl.initialise(ServerLocatorImpl.java:368) [hornetq-core-client-2.4.5.Final.jar:]
I've looked through the source code of HornetQ. It seems to be trying to unbind something not existing. I would not expect this to happen after the cluster bridge was constructed ...
Is this normal behavior? Maybe I might be missing something in the configuration. I can attach it if someone thinks it would help.
Thanks!