Last active
December 12, 2015 03:49
-
-
Save rabidpraxis/4710163 to your computer and use it in GitHub Desktop.
Clustered topic service issue
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 21:58:48,949 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-4) Calling close on session ClientSessionImpl [name=ea066553-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@4b6a82ce | |
| 21:58:48,950 DEBUG [org.hornetq.core.server.cluster.impl.ClusterConnectionImpl] (Thread-3 (HornetQ-client-global-threads-1049751023)) ClusterCommunication::Flow record on StaticClusterConnector [tcConfigs=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=192-168-100-30]] Receiving message ClientMessage[messageID=497111, durable=true, add | |
| ress=hornetq.notifications,properties=TypedProperties[{_HQ_User=5da5b37e-e815-4206-8f6d-a5e86acfabe1, _HQ_NotifTimestamp=1360015128944, _HQ_SessionName=0d66ca17-6f16-11e2-8333-af74519ce575, _HQ_Distance=0, _HQ_ClusterName=d179bca4-6c18-4521-ae1f-f2c4322dc798669d5bf6-6e94-11e2-a5aa-7f92ed790298, _HQ_Address=jms.topic./topics/remove_site_streams_accounts, _HQ_Noti | |
| fType=CONSUMER_CLOSED, _HQ_ConsumerCount=0, _HQ_RoutingName=d179bca4-6c18-4521-ae1f-f2c4322dc798, _HQ_RemoteAddress=invm:0, _HQ_FilterString=null}]] | |
| 21:58:48,950 DEBUG [org.hornetq.core.postoffice.impl.PostOfficeImpl] (Thread-3 (HornetQ-client-global-threads-1049751023)) Message ServerMessage[messageID=2238382,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_NotifTimestamp=1360015128950, _HQ_Distance=1, _HQ_NotifType=CONSUMER_CLOSED, _HQ_Addre | |
| ss=jms.topic./topics/remove_site_streams_accounts, _HQ_ClusterName=d179bca4-6c18-4521-ae1f-f2c4322dc798669d5bf6-6e94-11e2-a5aa-7f92ed790298, _HQ_RoutingName=d179bca4-6c18-4521-ae1f-f2c4322dc798, _HQ_ConsumerCount=1}]]@493701875 is not going anywhere as it didn't have a binding on address:hornetq.notifications | |
| 21:58:48,951 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-4) calling cleanup on ClientSessionImpl [name=ea066553-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], di | |
| scoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@4b6a82ce | |
| 21:58:48,951 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-2) Calling close on session ClientSessionImpl [name=ea0c58cc-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@707476dc | |
| 21:58:48,951 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-28 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d | |
| -6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,952 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-2) calling cleanup on ClientSessionImpl [name=ea0c58cc-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], di | |
| scoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@707476dc | |
| 21:58:48,952 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-8 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d- | |
| 6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,953 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-3) Calling close on session ClientSessionImpl [name=ea2e5ee4-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@3aa91f0d | |
| 21:58:48,954 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-3) calling cleanup on ClientSessionImpl [name=ea2e5ee4-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], di | |
| scoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@3aa91f0d | |
| 21:58:48,954 DEBUG [org.hornetq.core.server.cluster.impl.ClusterConnectionImpl] (Thread-4 (HornetQ-client-global-threads-1049751023)) ClusterCommunication::Flow record on StaticClusterConnector [tcConfigs=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=192-168-100-30]] Receiving message ClientMessage[messageID=497115, durable=true, add | |
| ress=hornetq.notifications,properties=TypedProperties[{_HQ_NotifTimestamp=1360015128949, _HQ_Distance=0, _HQ_ClusterName=d179bca4-6c18-4521-ae1f-f2c4322dc798669d5bf6-6e94-11e2-a5aa-7f92ed790298, _HQ_Address=jms.topic./topics/remove_site_streams_accounts, _HQ_NotifType=BINDING_REMOVED, _HQ_RoutingName=d179bca4-6c18-4521-ae1f-f2c4322dc798}]] | |
| 21:58:48,955 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-2) Calling close on session ClientSessionImpl [name=ea266f9a-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@4d64f65b | |
| 21:58:48,954 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-10 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d | |
| -6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,955 INFO [stdout] (Thread-4 (HornetQ-client-global-threads-1049751023)) Removing clusterName=d179bca4-6c18-4521-ae1f-f2c4322dc798669d5bf6-6e94-11e2-a5aa-7f92ed790298 on ClusterConnectionImpl@1204715407[nodeUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3, connector=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=192-168-100-28, addre | |
| ss=jms, server=HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3] | |
| 21:58:48,955 DEBUG [org.hornetq.core.postoffice.impl.PostOfficeImpl] (Thread-4 (HornetQ-client-global-threads-1049751023)) Message ServerMessage[messageID=2238392,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_NotifTimestamp=1360015128955, _HQ_Distance=1, _HQ_NotifType=BINDING_REMOVED, _HQ_Addre | |
| ss=jms.topic./topics/remove_site_streams_accounts, _HQ_ClusterName=d179bca4-6c18-4521-ae1f-f2c4322dc798669d5bf6-6e94-11e2-a5aa-7f92ed790298, _HQ_RoutingName=d179bca4-6c18-4521-ae1f-f2c4322dc798}]]@1918084764 is not going anywhere as it didn't have a binding on address:hornetq.notifications | |
| 21:58:48,955 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-2) calling cleanup on ClientSessionImpl [name=ea266f9a-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], di | |
| scoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@4d64f65b | |
| 21:58:48,955 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-1) Calling close on session ClientSessionImpl [name=ea1de410-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@2feadcf9 | |
| 21:58:48,956 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-1) calling cleanup on ClientSessionImpl [name=ea1de410-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], di | |
| scoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@2feadcf9 | |
| 21:58:48,957 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-4) Calling close on session ClientSessionImpl [name=ea0bbc8b-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@5464cba3 | |
| 21:58:48,959 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-9 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d- | |
| 6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,959 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-9 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d- | |
| 6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,959 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-9 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d- | |
| 6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,959 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-4) calling cleanup on ClientSessionImpl [name=ea0bbc8b-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], di | |
| scoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@5464cba3 | |
| 21:58:48,960 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-2) Calling close on session ClientSessionImpl [name=ea2d7482-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@442c973d | |
| 21:58:48,960 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-2) calling cleanup on ClientSessionImpl [name=ea2d7482-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], di | |
| scoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@442c973d | |
| 21:58:48,961 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-1) Calling close on session ClientSessionImpl [name=ea19c55a-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@55308571 | |
| 21:58:48,961 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-1) calling cleanup on ClientSessionImpl [name=ea19c55a-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], di | |
| scoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@55308571 | |
| 21:58:48,962 DEBUG [org.hornetq.core.server.cluster.impl.ClusterConnectionImpl] (Thread-4 (HornetQ-client-global-threads-1049751023)) ClusterCommunication::Flow record on StaticClusterConnector [tcConfigs=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=192-168-100-30]] Receiving message ClientMessage[messageID=497129, durable=true, add | |
| ress=hornetq.notifications,properties=TypedProperties[{_HQ_Binding_ID=497128, _HQ_Binding_Type=0, _HQ_NotifTimestamp=1360015128957, _HQ_Distance=0, _HQ_ClusterName=fa7c24fb-ee24-4929-8d1a-48313743a8cc669d5bf6-6e94-11e2-a5aa-7f92ed790298, _HQ_Address=jms.topic./topics/remove_site_streams_accounts, _HQ_NotifType=BINDING_ADDED, _HQ_RoutingName=fa7c24fb-ee24-4929-8d | |
| 1a-48313743a8cc, foobar=0e02e313-6f16-11e2-8333-af74519ce575}]] | |
| 21:58:48,962 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (MSC service thread 1-3) Calling close on session ClientSessionImpl [name=ea20f154-6f15-11e2-afc1-e3b741686c19, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id= | |
| 0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@77638a90 | |
| 21:58:48,962 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-18 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d | |
| -6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,963 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-20 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d | |
| -6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,962 DEBUG [org.hornetq.core.postoffice.impl.SimpleAddressManager] (Thread-4 (HornetQ-client-global-threads-1049751023)) Adding binding RemoteQueueBindingImpl [address=jms.topic./topics/remove_site_streams_accounts, consumerCount=0, distance=1, filters=[], id=2238403, idsHeaderName=_HQ_ROUTE_TOsf.my-cluster.669d5bf6-6e94-11e2-a5aa-7f92ed790298, queueFilt | |
| er=null, remoteQueueID=497128, routingName=fa7c24fb-ee24-4929-8d1a-48313743a8cc, storeAndForwardQueue=QueueImpl[name=sf.my-cluster.669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3]]@73606be2, uniqueName=fa7c24fb-ee24-4929-8d1a-48313743a8cc669d5bf6-6e94-11e2-a5aa-7f92ed79029 | |
| 8] with address = fa7c24fb-ee24-4929-8d1a-48313743a8cc669d5bf6-6e94-11e2-a5aa-7f92ed790298: java.lang.Exception: trace | |
| at org.hornetq.core.postoffice.impl.SimpleAddressManager.addBinding(SimpleAddressManager.java:65) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.postoffice.impl.WildcardAddressManager.addBinding(WildcardAddressManager.java:98) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.postoffice.impl.PostOfficeImpl.addBinding(PostOfficeImpl.java:452) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.server.cluster.impl.ClusterConnectionImpl$MessageFlowRecordImpl.doBindingAdded(ClusterConnectionImpl.java:1388) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.server.cluster.impl.ClusterConnectionImpl$MessageFlowRecordImpl.onMessage(ClusterConnectionImpl.java:1213) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1028) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:50) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1173) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:100) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) [rt.jar:1.7.0_11] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) [rt.jar:1.7.0_11] | |
| at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_11] | |
| 21:58:48,963 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-19 (HornetQ-server-HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3-472243180)) QueueImpl[name=notif.e734f5a4-6f15-11e2-8333-af74519ce575.HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3]]@65b024e9 doing deliver. messageReferences=1 | |
| 21:58:48,963 DEBUG [org.hornetq.core.postoffice.impl.PostOfficeImpl] (Thread-4 (HornetQ-client-global-threads-1049751023)) ClusterCommunication::Sending notification for addBinding RemoteQueueBindingImpl [address=jms.topic./topics/remove_site_streams_accounts, consumerCount=0, distance=1, filters=[], id=2238403, idsHeaderName=_HQ_ROUTE_TOsf.my-cluster.669d5bf6-6e94-11e2-a5aa-7f92ed790298, queueFilter=null, remoteQueueID=497128, routingName=fa7c24fb-ee24-4929-8d1a-48313743a8cc, storeAndForwardQueue=QueueImpl[name=sf.my-cluster.669d5bf6-6e94-11e2-a5aa-7f92ed790298, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3]]@73606be2, uniqueName=fa7c24fb-ee24-4929-8d1a-48313743a8cc669d5bf6-6e94-11e2-a5aa-7f92ed790298] from server HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3 | |
| 21:58:48,964 DEBUG [org.hornetq.core.postoffice.impl.PostOfficeImpl] (Thread-4 (HornetQ-client-global-threads-1049751023)) Message ServerMessage[messageID=2238410,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_NotifTimestamp=1360015128964, _HQ_Binding_Type=1, _HQ_Binding_ID=2238403, _HQ_Distance=1, _HQ_NotifType=BINDING_ADDED, _HQ_Address=jms.topic./topics/remove_site_streams_accounts, _HQ_ClusterName=fa7c24fb-ee24-4929-8d1a-48313743a8cc669d5bf6-6e94-11e2-a5aa-7f92ed790298, _HQ_RoutingName=fa7c24fb-ee24-4929-8d1a-48313743a8cc, foobar=0e03cdd4-6f16-11e2-afc1-e3b741686c19}]]@1373603431 is not going anywhere as it didn't have a binding on address:hornetq.notifications |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 21:59:05,537 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) Calling close on session ClientSessionImpl [name=174ad579-6f16-11e2-8333-af74519ce575, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=Ser | |
| verLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@7f3e004f | |
| 21:59:05,538 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) calling cleanup on ClientSessionImpl [name=174ad579-6f16-11e2-8333-af74519ce575, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLoc | |
| atorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@7f3e004f | |
| 21:59:05,538 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) Calling close on session ClientSessionImpl [name=174aae68-6f16-11e2-8333-af74519ce575, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=Ser | |
| verLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@2955e783 | |
| 21:59:05,539 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) calling cleanup on ClientSessionImpl [name=174aae68-6f16-11e2-8333-af74519ce575, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLoc | |
| atorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@2955e783 | |
| 21:59:05,539 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) Session was already closed, giving up now, this=ClientSessionImpl [name=174aae68-6f16-11e2-8333-af74519ce575, username=null, closed=true, factory = ClientSessionFactoryI | |
| mpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@2955e783 | |
| 21:59:05,539 DEBUG [org.hornetq.core.client.impl.ClientSessionFactoryImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) Trying reconnection attempt 0/1 | |
| 21:59:05,539 DEBUG [org.hornetq.core.client.impl.ClientSessionFactoryImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) Trying to connect with connector = org.hornetq.core.remoting.impl.invm.InVMConnectorFactory@79d3cc5, parameters = {server-id=0} connector = org.hornetq.core.remot | |
| ing.impl.invm.InVMConnector@6400ad6a | |
| 21:59:05,539 DEBUG [org.hornetq.core.client.impl.ClientSessionFactoryImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) Trying to connect at the main server using connector :org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0 | |
| 21:59:05,539 DEBUG [org.hornetq.core.client.impl.ClientSessionFactoryImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) Reconnection successfull | |
| 21:59:05,539 DEBUG [org.hornetq.core.client.impl.ClientSessionFactoryImpl] (RubyThread-114: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) ClientSessionFactoryImpl received backup update for live/backup pair = org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0 / null but it didn't b | |
| elong to org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0 | |
| 21:59:05,540 DEBUG [org.hornetq.core.client.impl.ClientSessionFactoryImpl] (Thread-7 (HornetQ-client-global-threads-921545941)) Node 669d5bf6-6e94-11e2-a5aa-7f92ed790298 going up, connector = Pair[a=null, b=null], isLast=true csf created at | |
| serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], discoveryGroupConfiguration=null]: java.lang.Exception | |
| at org.hornetq.core.client.impl.ClientSessionFactoryImpl.<init>(ClientSessionFactoryImpl.java:181) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.client.impl.ServerLocatorImpl.createSessionFactory(ServerLocatorImpl.java:737) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.jms.client.HornetQConnectionFactory.createConnectionInternal(HornetQConnectionFactory.java:601) [hornetq-jms-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.jms.client.HornetQConnectionFactory.createConnection(HornetQConnectionFactory.java:119) [hornetq-jms-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at sun.reflect.GeneratedMethodAccessor15.invoke(Unknown Source) [:1.7.0_11] | |
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.7.0_11] | |
| at java.lang.reflect.Method.invoke(Method.java:601) [rt.jar:1.7.0_11] | |
| at org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(JavaMethod.java:470) | |
| at org.jruby.javasupport.JavaMethod.invokeDirect(JavaMethod.java:328) | |
| at org.jruby.java.invokers.InstanceMethodInvoker.call(InstanceMethodInvoker.java:71) | |
| at org.jruby.internal.runtime.methods.AliasMethod.call(AliasMethod.java:66) | |
| at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:202) | |
| at rubyjit.TorqueBox::Messaging::ConnectionFactory$$create_connection_3F98D4A37ED3ECA10130DF3BEC2ECE453370C82F1150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/connection_factory.rb:58) | |
| at rubyjit.TorqueBox::Messaging::ConnectionFactory$$create_connection_3F98D4A37ED3ECA10130DF3BEC2ECE453370C82F1150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/connection_factory.rb) | |
| at org.jruby.internal.runtime.methods.JittedMethod.call(JittedMethod.java:181) | |
| at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:168) | |
| at rubyjit.TorqueBox::Messaging::ConnectionFactory$$with_new_connection_C41F193B2C57FF18B9969005FCDC8219645F0F7F1150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/connection_factory.rb:38) | |
| at rubyjit.TorqueBox::Messaging::ConnectionFactory$$with_new_connection_C41F193B2C57FF18B9969005FCDC8219645F0F7F1150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/connection_factory.rb) | |
| at org.jruby.internal.runtime.methods.JittedMethod.call(JittedMethod.java:201) | |
| at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:177) | |
| at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:188) | |
| at rubyjit.TorqueBox::Messaging::Destination$$with_session_31216DFB657D46F27781C6C1BDB86AB8AE8A2DB51150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb:110) | |
| at rubyjit.TorqueBox::Messaging::Destination$$with_session_31216DFB657D46F27781C6C1BDB86AB8AE8A2DB51150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb) | |
| at org.jruby.ast.executable.AbstractScript.__file__(AbstractScript.java:42) | |
| at org.jruby.internal.runtime.methods.JittedMethod.call(JittedMethod.java:201) | |
| at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:177) | |
| at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:188) | |
| at rubyjit.TorqueBox::Messaging::Destination$$receive_D2E70610DB0E613E7D2C53146E636315F28A3B411150390318.block_1$RUBY$__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb:82) | |
| at rubyjit$TorqueBox::Messaging::Destination$$receive_D2E70610DB0E613E7D2C53146E636315F28A3B411150390318$block_1$RUBY$__file__.call(rubyjit$TorqueBox::Messaging::Destination$$receive_D2E70610DB0E613E7D2C53146E636315F28A3B411150390318$block_1$RUBY$__file__) at org.jruby.runtime.CompiledBlock19.yield(CompiledBlock19.java:163) | |
| at org.jruby.runtime.CompiledBlock19.call(CompiledBlock19.java:91) | |
| at org.jruby.runtime.Block.call(Block.java:89) | |
| at org.jruby.RubyProc.call(RubyProc.java:261) | |
| at org.jruby.RubyProc.call19(RubyProc.java:249) | |
| at org.jruby.RubyProc$INVOKER$i$0$0$call19.call(RubyProc$INVOKER$i$0$0$call19.gen) | |
| at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200) | |
| at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:196) | |
| at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:134) | |
| at rubyjit.TorqueBox::Messaging::Destination$$receive_D2E70610DB0E613E7D2C53146E636315F28A3B411150390318.block_0$RUBY$__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb:89) | |
| at rubyjit$TorqueBox::Messaging::Destination$$receive_D2E70610DB0E613E7D2C53146E636315F28A3B411150390318$block_0$RUBY$__file__.call(rubyjit$TorqueBox::Messaging::Destination$$receive_D2E70610DB0E613E7D2C53146E636315F28A3B411150390318$block_0$RUBY$__file__) at org.jruby.runtime.CompiledBlock19.yield(CompiledBlock19.java:163) | |
| at org.jruby.runtime.CompiledBlock19.call(CompiledBlock19.java:91) | |
| at org.jruby.runtime.Block.call(Block.java:89) | |
| at org.jruby.RubyProc.call(RubyProc.java:261) | |
| at org.jruby.RubyProc.call19(RubyProc.java:249) | |
| at org.jruby.RubyProc$INVOKER$i$0$0$call19.call(RubyProc$INVOKER$i$0$0$call19.gen) | |
| at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:200) | |
| at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:196) | |
| at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:134) | |
| at rubyjit.TorqueBox::Messaging::Destination$$wait_for_destination_CBBFEB14B4A03E4FA02C6D6003D720ABFD21E8051150390318.chained_0_rescue_1$RUBY$SYNTHETIC__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb:121) | |
| at rubyjit.TorqueBox::Messaging::Destination$$wait_for_destination_CBBFEB14B4A03E4FA02C6D6003D720ABFD21E8051150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb:120) | |
| at rubyjit.TorqueBox::Messaging::Destination$$wait_for_destination_CBBFEB14B4A03E4FA02C6D6003D720ABFD21E8051150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb) | |
| at org.jruby.ast.executable.AbstractScript.__file__(AbstractScript.java:42) | |
| at org.jruby.internal.runtime.methods.JittedMethod.call(JittedMethod.java:201) | |
| at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:177) | |
| at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:188) | |
| at rubyjit.TorqueBox::Messaging::Destination$$receive_D2E70610DB0E613E7D2C53146E636315F28A3B411150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb:80) | |
| at rubyjit.TorqueBox::Messaging::Destination$$receive_D2E70610DB0E613E7D2C53146E636315F28A3B411150390318.__file__(/srv/digital_wristband/current/vendor/bundle/jruby/1.9/gems/torquebox-messaging-2.3.0-java/lib/torquebox/messaging/destination.rb) | |
| at org.jruby.ast.executable.AbstractScript.__file__(AbstractScript.java:42) | |
| at org.jruby.internal.runtime.methods.JittedMethod.call(JittedMethod.java:181) | |
| at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:168) | |
| at org.jruby.ast.CallOneArgNode.interpret(CallOneArgNode.java:57) | |
| at org.jruby.ast.DAsgnNode.interpret(DAsgnNode.java:110) | |
| at org.jruby.ast.IfNode.interpret(IfNode.java:110) | |
| at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105) | |
| at org.jruby.ast.UntilNode.interpret(UntilNode.java:120) | |
| at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105) | |
| at org.jruby.ast.BlockNode.interpret(BlockNode.java:71) | |
| at org.jruby.ast.RescueNode.interpret(RescueNode.java:119) | |
| at org.jruby.ast.BeginNode.interpret(BeginNode.java:83) | |
| at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105) | |
| at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:112) | |
| at org.jruby.runtime.Interpreted19Block.evalBlockBody(Interpreted19Block.java:209) | |
| at org.jruby.runtime.Interpreted19Block.yield(Interpreted19Block.java:197) | |
| at org.jruby.runtime.Interpreted19Block.call(Interpreted19Block.java:128) | |
| at org.jruby.runtime.Block.call(Block.java:89) | |
| at org.jruby.RubyProc.call(RubyProc.java:261) | |
| at org.jruby.RubyProc.call(RubyProc.java:213) | |
| at org.jruby.internal.runtime.RubyRunnable.run(RubyRunnable.java:98) | |
| at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_11] | |
| 21:59:05,545 DEBUG [org.hornetq.core.client.impl.ServerLocatorImpl] (Thread-7 (HornetQ-client-global-threads-921545941)) NodeUp ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], discoveryGroupConfiguration=null]::nodeID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, connectorPair=Pair[a=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, b=null]: java.lang.Exception: trace | |
| at org.hornetq.core.client.impl.ServerLocatorImpl.notifyNodeUp(ServerLocatorImpl.java:1398) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.client.impl.ClientSessionFactoryImpl$Channel0Handler$2.run(ClientSessionFactoryImpl.java:1529) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) [rt.jar:1.7.0_11] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) [rt.jar:1.7.0_11] | |
| at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_11] | |
| 21:59:05,545 DEBUG [org.hornetq.core.client.impl.Topology] (Thread-7 (HornetQ-client-global-threads-921545941)) Topology@2b7a595d::updated currentMember=nodeID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, currentMember=TopologyMember[connector=Pair[a=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, b=null]], memberInput=TopologyMember[connector=Pair[a=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, b=null]]newMember=TopologyMember[connector=Pair[a=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, b=null]]: java.lang.Exception: trace | |
| at org.hornetq.core.client.impl.Topology.updateMember(Topology.java:209) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.client.impl.ServerLocatorImpl.notifyNodeUp(ServerLocatorImpl.java:1403) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.client.impl.ClientSessionFactoryImpl$Channel0Handler$2.run(ClientSessionFactoryImpl.java:1529) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) [rt.jar:1.7.0_11] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) [rt.jar:1.7.0_11] | |
| at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_11] | |
| 21:59:05,547 DEBUG [org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) jms.topic./topics/add_site_streams_accounts creating subscription 497922 with filter null: java.lang.Exception: trace | |
| at org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl.createSubscription(PageCursorProviderImpl.java:94) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] at org.hornetq.core.server.impl.HornetQServerImpl.createQueue(HornetQServerImpl.java:1750) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.server.impl.HornetQServerImpl.createQueue(HornetQServerImpl.java:986) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.server.impl.ServerSessionImpl.createQueue(ServerSessionImpl.java:415) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.protocol.core.ServerSessionPacketHandler.handlePacket(ServerSessionPacketHandler.java:231) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.protocol.core.impl.ChannelImpl.handlePacket(ChannelImpl.java:508) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:556) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:517) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:534) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] at org.hornetq.core.remoting.impl.invm.InVMConnection$1.run(InVMConnection.java:169) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:100) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) [rt.jar:1.7.0_11] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) [rt.jar:1.7.0_11] | |
| at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_11] | |
| 21:59:05,548 DEBUG [org.hornetq.core.postoffice.impl.SimpleAddressManager] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) Adding binding LocalQueueBinding [address=jms.topic./topics/add_site_streams_accounts, queue=QueueImpl[name=fa7a4789-75ab-4a3a-b4f7-414124127bd8, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@24897d31, filter=null, name=fa7a4789-75ab-4a3a-b4f7-414124127bd8, clusterName=fa7a4789-75ab-4a3a-b4f7-414124127bd8669d5bf6-6e94-11e2-a5aa-7f92ed790298] with address = fa7a4789-75ab-4a3a-b4f7-414124127bd8: java.lang.Exception: trace | |
| at org.hornetq.core.postoffice.impl.SimpleAddressManager.addBinding(SimpleAddressManager.java:65) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.postoffice.impl.WildcardAddressManager.addBinding(WildcardAddressManager.java:98) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.postoffice.impl.PostOfficeImpl.addBinding(PostOfficeImpl.java:452) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.server.impl.HornetQServerImpl.createQueue(HornetQServerImpl.java:1772) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.server.impl.HornetQServerImpl.createQueue(HornetQServerImpl.java:986) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.server.impl.ServerSessionImpl.createQueue(ServerSessionImpl.java:415) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.protocol.core.ServerSessionPacketHandler.handlePacket(ServerSessionPacketHandler.java:231) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.protocol.core.impl.ChannelImpl.handlePacket(ChannelImpl.java:508) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:556) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:517) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:534) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.core.remoting.impl.invm.InVMConnection$1.run(InVMConnection.java:169) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:100) [hornetq-core-2.2.21.Final.jar:2.2.21.SNAPSHOT (HQ_2_2_21_final, 122)] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) [rt.jar:1.7.0_11] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) [rt.jar:1.7.0_11] | |
| at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_11] | |
| 21:59:05,548 DEBUG [org.hornetq.core.postoffice.impl.PostOfficeImpl] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) ClusterCommunication::Sending notification for addBinding LocalQueueBinding [address=jms.topic./topics/add_site_streams_accounts, queue=QueueImpl[name=fa7a4789-75ab-4a3a-b4f7-414124127bd8, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@24897d31, filter=null, name=fa7a4789-75ab-4a3a-b4f7-414124127bd8, clusterName=fa7a4789-75ab-4a3a-b4f7-414124127bd8669d5bf6-6e94-11e2-a5aa-7f92ed790298] from server HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298 | |
| 21:59:05,548 DEBUG [org.hornetq.core.server.management.impl.ManagementServiceImpl] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) registered address org.hornetq:module=Core,type=Address,name="jms.topic./topics/add_site_streams_accounts" | |
| 21:59:05,549 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-22 (HornetQ-server-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-399932890)) QueueImpl[name=notif.1246594a-6f16-11e2-ba93-39281957fdc8.HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@6abb1c42 doing deliver. messageReferences=1 | |
| 21:59:05,549 DEBUG [org.hornetq.core.server.management.impl.ManagementServiceImpl] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) registered queue org.hornetq:module=Core,type=Queue,address="jms.topic./topics/add_site_streams_accounts",name="fa7a4789-75ab-4a3a-b4f7-414124127bd8" | |
| 21:59:05,549 DEBUG [org.hornetq.core.server.impl.ServerSessionImpl] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) Queue fa7a4789-75ab-4a3a-b4f7-414124127bd8 created on address fa7a4789-75ab-4a3a-b4f7-414124127bd8 with filter=null temporary = true durable=false on session user=5da5b37e-e815-4206-8f6d-a5e86acfabe1, connection=RemotingConnectionImpl [clientID=null, nodeID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, transportConnection=InVMConnection [serverID=0, id=17e519b2-6f16-11e2-8333-af74519ce575]] | |
| 21:59:05,550 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) QueueImpl[name=fa7a4789-75ab-4a3a-b4f7-414124127bd8, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@24897d31 adding consumer org.hornetq.core.server.impl.ServerConsumerImpl@3e7a2eb4 | |
| 21:59:05,550 DEBUG [org.hornetq.core.server.impl.ServerSessionImpl] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) Session with user=5da5b37e-e815-4206-8f6d-a5e86acfabe1, connection=RemotingConnectionImpl [clientID=null, nodeID=669d5bf6-6e94-11e2-a5aa-7f92ed790298, transportConnection=InVMConnection [serverID=0, id=17e519b2-6f16-11e2-8333-af74519ce575]] created a consumer on queue fa7a4789-75ab-4a3a-b4f7-414124127bd8, filter = null | |
| 21:59:05,550 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-0 (HornetQ-server-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-399932890)) QueueImpl[name=notif.1246594a-6f16-11e2-ba93-39281957fdc8.HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@6abb1c42 doing deliver. messageReferences=1 | |
| 21:59:05,550 DEBUG [org.hornetq.core.server.impl.ServerConsumerImpl] (Thread-4 (HornetQ-remoting-threads-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-1713950866-26564004)) org.hornetq.core.server.impl.ServerConsumerImpl@3e7a2eb4::FlowControl::Received 1 credits, previous value = 0 currentValue = 1 | |
| 21:59:05,550 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-17 (HornetQ-server-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-399932890)) QueueImpl[name=fa7a4789-75ab-4a3a-b4f7-414124127bd8, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@24897d31 doing deliver. messageReferences=0 | |
| 21:59:06,268 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-24 (HornetQ-server-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-399932890)) QueueImpl[name=a8aca3fd-e414-412a-b1b4-103b2dd771f8, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@53291580 doing deliver. messageReferences=021:59:06,268 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-1 (HornetQ-server-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-399932890)) QueueImpl[name=notif.1246594a-6f16-11e2-ba93-39281957fdc8.HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@6abb1c42 doing deliver. messageReferences=1 | |
| 21:59:06,269 DEBUG [org.hornetq.core.server.impl.QueueImpl] (Thread-13 (HornetQ-server-HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298-399932890)) QueueImpl[name=notif.1246594a-6f16-11e2-ba93-39281957fdc8.HornetQServerImpl::serverUUID=adc2ff4d-6dd7-11e2-812f-a95b4525e2b3, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=669d5bf6-6e94-11e2-a5aa-7f92ed790298]]@6abb1c42 doing deliver. messageReferences=1 | |
| 21:59:06,270 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (RubyThread-115: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) Calling close on session ClientSessionImpl [name=17bad55f-6f16-11e2-8333-af74519ce575, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0], discoveryGroupConfiguration=null], connectorConfig=org-hornetq-core-remoting-impl-invm-InVMConnectorFactory?server-id=0, backupConfig=null], metaData=(jms-session=,)]@a96a4de21:59:06,270 DEBUG [org.hornetq.core.client.impl.ClientSessionImpl] (RubyThread-115: /srv/digital_wristband/releases/ebea0c7cc1f28a22eb4249d0bb2d74200ba8ffcc/app/services/stream_collector.rb:76) calling cleanup on ClientSessionImpl [name=17bad55f-6f16-11e2-8333-af74519ce575, username=null, closed=false, factory = ClientSessionFactoryImpl [serverLocator=ServerLoc | |
| at org.jruby.ast.RescueNode.executeBody(RescueNode.java:224) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| class StreamCollector | |
| def initialize(opts={}) | |
| @done = false | |
| end | |
| def start | |
| create_topic('add_site_streams_accounts', :add_accounts) | |
| create_topic('remove_site_streams_accounts', :remove_accounts) | |
| end | |
| def create_topic(topic_name, method_name) | |
| Thread.new do | |
| begin | |
| topic = TorqueBox::Messaging::Topic.new("/topics/#{topic_name}") | |
| until @done | |
| if data = topic.receive(:timeout => 1000) | |
| send(method_name, [data[:acct]]) | |
| end | |
| end | |
| rescue Exception => e | |
| p "#{topic_name} err #{e}\n#{e.backtrace}" | |
| start | |
| end | |
| end | |
| end | |
| def stop | |
| @done = true | |
| end | |
| end | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| TorqueBox.configure do | |
| pool :web, :type => :shared | |
| pool :jobs, :type => :shared, :lazy => false | |
| pool :messaging, :type => :shared, :lazy => false | |
| pool :services, :type => :shared, :lazy => false | |
| service StreamCollector | |
| topic '/topics/add_site_streams_accounts' | |
| topic '/topics/remove_site_streams_accounts' | |
| ruby do | |
| version '1.9' | |
| end | |
| end |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment