2016-12-15 10:21:09,376 [main ] - INFO NetworkBrokersTest - Starting up 2016-12-15 10:21:09,459 [main ] - INFO ClassPathXmlApplicationContext - Refreshing org.apache.xbean.spring.context.ClassPathXmlApplicationContext@799d4f69: startup date [Thu Dec 15 10:21:09 CET 2016]; root of context hierarchy 2016-12-15 10:21:09,506 [main ] - INFO XBeanXmlBeanDefinitionReader - Loading XML bean definitions from class path resource [NetworkBrokersTest.xml] 2016-12-15 10:21:09,962 [main ] - INFO DefaultListableBeanFactory - Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@77659b30: defining beans [broker1,broker2,mysql-ds]; root of factory hierarchy 2016-12-15 10:21:10,122 [main ] - WARN BrokerService - persistent="false", ignoring configured persistenceAdapter: KahaDBPersistenceAdapter[/Users/tmielke/Projects/TestCases/USInternalRevenueService/01730594/BrokerNetworkReconnectProblem/./target/activemq-data-broker1] 2016-12-15 10:21:10,220 [main ] - INFO BrokerService - Using Persistence Adapter: MemoryPersistenceAdapter 2016-12-15 10:21:10,275 [JMX connector ] - INFO ManagementContext - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi 2016-12-15 10:21:10,367 [main ] - INFO BrokerService - Apache ActiveMQ 5.11.0.redhat-621084 (broker1, ID:Mac.fritz.box-55990-1481793670235-0:1) is starting 2016-12-15 10:21:10,380 [main ] - INFO TransportServerThreadSupport - Listening for connections at: tcp://Mac.fritz.box:61626 2016-12-15 10:21:10,380 [main ] - INFO TransportConnector - Connector openwire3 started 2016-12-15 10:21:10,405 [main ] - INFO TransportServerThreadSupport - Listening for connections at: nio+ssl://Mac.fritz.box:61616 2016-12-15 10:21:10,405 [main ] - INFO TransportConnector - Connector openwire1 started 2016-12-15 10:21:10,406 [main ] - INFO DiscoveryNetworkConnector - Establishing network connection from vm://broker1?async=false&network=true to failover:(ssl://localhost:62616?trace=true,tcp://localhost:61629)?randomize=false&maxReconnectAttempts=0 2016-12-15 10:21:10,423 [main ] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-15 10:21:10,427 [main ] - INFO TransportConnector - Connector vm://broker1 started 2016-12-15 10:21:10,448 [main ] - DEBUG FailoverTransport - Started unconnected 2016-12-15 10:21:10,448 [main ] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-15 10:21:10,448 [ActiveMQ Task-1] - DEBUG FailoverTransport - urlList connectionList:[ssl://localhost:62616?trace=true, tcp://localhost:61629], from: [ssl://localhost:62616?trace=true, tcp://localhost:61629] 2016-12-15 10:21:10,450 [main ] - INFO NetworkConnector - Network Connector DiscoveryNetworkConnector:test-broker1-to-broker2:BrokerService[broker1] started 2016-12-15 10:21:10,450 [main ] - INFO BrokerService - Apache ActiveMQ 5.11.0.redhat-621084 (broker1, ID:Mac.fritz.box-55990-1481793670235-0:1) started 2016-12-15 10:21:10,450 [main ] - INFO BrokerService - For help or more information please see: http://activemq.apache.org 2016-12-15 10:21:10,485 [main ] - INFO PListStoreImpl - PListStore:[/Users/tmielke/Projects/TestCases/USInternalRevenueService/01730594/BrokerNetworkReconnectProblem/./target/activemq-data-broker2/broker2/tmp_storage] started 2016-12-15 10:21:10,489 [main ] - INFO BrokerService - Using Persistence Adapter: JDBCPersistenceAdapter(org.apache.commons.dbcp.BasicDataSource@6a62689d) 2016-12-15 10:21:10,491 [JMX connector ] - INFO ManagementContext - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1199/jmxrmi 2016-12-15 10:21:10,582 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: ssl://localhost:62616?trace=true 2016-12-15 10:21:10,583 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connect fail to: ssl://localhost:62616?trace=true, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:10,585 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:61629 2016-12-15 10:21:10,586 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:61629, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:10,586 [ActiveMQ Task-1] - ERROR FailoverTransport - Failed to connect to [ssl://localhost:62616?trace=true, tcp://localhost:61629] after: 1 attempt(s) 2016-12-15 10:21:10,586 [ vm://broker1#0] - INFO DemandForwardingBridgeSupport - Network connection between vm://broker1#0 and unconnected shutdown due to a local error: java.lang.Throwable: remoteBrokerInfo is null 2016-12-15 10:21:10,587 [ vm://broker1#0] - DEBUG DemandForwardingBridgeSupport - The local Exception was: java.lang.Throwable: remoteBrokerInfo is null java.lang.Throwable: remoteBrokerInfo is null at org.apache.activemq.network.DemandForwardingBridgeSupport.collectBrokerInfos(DemandForwardingBridgeSupport.java:351) at org.apache.activemq.network.DemandForwardingBridgeSupport.access$400(DemandForwardingBridgeSupport.java:106) at org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:332) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:21:10,590 [broker1] Task-1] - DEBUG DemandForwardingBridgeSupport - stopping broker1 bridge to Unknown 2016-12-15 10:21:10,594 [broker1] Task-1] - DEBUG FailoverTransport - Stopped unconnected 2016-12-15 10:21:10,594 [broker1] Task-1] - INFO TransportConnector - Connector vm://broker1 stopped 2016-12-15 10:21:10,594 [broker1] Task-1] - INFO DemandForwardingBridgeSupport - broker1 bridge to Unknown stopped 2016-12-15 10:21:10,749 [main ] - INFO JDBCPersistenceAdapter - Database adapter driver override recognized for : [mysql_connector_java] - adapter: class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter 2016-12-15 10:21:10,924 [main ] - INFO JDBCPersistenceAdapter - Persistence store purged. 2016-12-15 10:21:10,959 [main ] - INFO LeaseDatabaseLocker - broker2 attempting to acquire exclusive lease to become the master 2016-12-15 10:21:10,979 [main ] - INFO LeaseDatabaseLocker - broker2, becoming master with lease expiry Thu Dec 15 13:07:50 CET 2016 on dataSource: org.apache.commons.dbcp.BasicDataSource@6a62689d 2016-12-15 10:21:10,983 [main ] - INFO BrokerService - Apache ActiveMQ 5.11.0.redhat-621084 (broker2, ID:Mac.fritz.box-55990-1481793670235-0:2) is starting 2016-12-15 10:21:10,988 [main ] - INFO TransportServerThreadSupport - Listening for connections at: tcp://Mac.fritz.box:62626?transport.trace=false 2016-12-15 10:21:10,989 [main ] - INFO TransportConnector - Connector openwire4 started 2016-12-15 10:21:10,990 [main ] - INFO TransportServerThreadSupport - Listening for connections at: nio+ssl://Mac.fritz.box:62616?transport.trace=false 2016-12-15 10:21:10,990 [main ] - INFO TransportConnector - Connector openwire2 started 2016-12-15 10:21:10,990 [main ] - INFO BrokerService - Apache ActiveMQ 5.11.0.redhat-621084 (broker2, ID:Mac.fritz.box-55990-1481793670235-0:2) started 2016-12-15 10:21:10,990 [main ] - INFO BrokerService - For help or more information please see: http://activemq.apache.org 2016-12-15 10:21:10,995 [main ] - INFO NetworkBrokersTest - Broker broker already started. Not kicking it off a second time. 2016-12-15 10:21:10,995 [main ] - INFO NetworkBrokersTest - testing tmp storage 2016-12-15 10:21:11,013 [Thread-4 ] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-15 10:21:11,015 [Thread-4 ] - DEBUG FailoverTransport - Started unconnected 2016-12-15 10:21:11,015 [Thread-4 ] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-15 10:21:11,015 [ActiveMQ Task-1] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:11,015 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:62626 2016-12-15 10:21:11,018 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connection established 2016-12-15 10:21:11,018 [ActiveMQ Task-1] - INFO FailoverTransport - Successfully connected to tcp://localhost:62626 2016-12-15 10:21:11,026 [0.1:62626@55999] - TRACE FailoverTransport - Received ConnectionControl: ConnectionControl {commandId = 0, responseRequired = false, suspend = false, resume = false, close = false, exit = false, faultTolerant = false, connectedBrokers = , reconnectTo = , token = null, rebalanceConnection = false} 2016-12-15 10:21:11,592 [ActiveMQ Task-1] - INFO DiscoveryNetworkConnector - Establishing network connection from vm://broker1?async=false&network=true to failover:(ssl://localhost:62616?trace=true,tcp://localhost:61629)?randomize=false&maxReconnectAttempts=0 2016-12-15 10:21:11,593 [ActiveMQ Task-1] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-15 10:21:11,593 [ActiveMQ Task-1] - INFO TransportConnector - Connector vm://broker1 started 2016-12-15 10:21:11,593 [ActiveMQ Task-1] - DEBUG FailoverTransport - Started unconnected 2016-12-15 10:21:11,593 [ActiveMQ Task-1] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-15 10:21:11,593 [ActiveMQ Task-1] - DEBUG FailoverTransport - urlList connectionList:[ssl://localhost:62616?trace=true, tcp://localhost:61629], from: [ssl://localhost:62616?trace=true, tcp://localhost:61629] 2016-12-15 10:21:11,595 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: ssl://localhost:62616?trace=true 2016-12-15 10:21:11,596 [ActiveMQ Task-1] - DEBUG Connection:2 - SENDING: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 2016-12-15 10:21:11,645 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connection established 2016-12-15 10:21:11,645 [ActiveMQ Task-1] - INFO FailoverTransport - Successfully connected to ssl://localhost:62616?trace=true 2016-12-15 10:21:11,646 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 2016-12-15 10:21:11,647 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-55990-1481793670235-0:2, brokerURL = tcp://Mac.fritz.box:62626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker2, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-15 10:21:11,652 [ vm://broker1#2] - INFO DemandForwardingBridgeSupport - Network connection between vm://broker1#2 and ssl://localhost:62616?trace=true (broker2) has been established. 2016-12-15 10:21:11,654 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: BrokerInfo {commandId = 1, responseRequired = false, brokerId = ID:Mac.fritz.box-55990-1481793670235-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = true, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = # #Thu Dec 15 10:21:11 CET 2016 messageTTL=2 staticBridge=false started=true useCompression=false conduitSubscriptions=false advisoryForFailedForward=false gcSweepTime=60000 bridgeTempDestinations=true stopped=false uri=masterslave\:(ssl\://localhost\:62616?trace\=true,tcp\://localhost\:61629) gcDestinationViews=true destinationFilter=ActiveMQ.Advisory.Consumer.> dynamicOnly=false brokerName=broker1 consumerTTL=2 prefetchSize=1000 alwaysSyncSend=true dispatchAsync=true brokerURL=tcp\://Mac.fritz.box\:61626 duplex=false consumerPriorityBase=-5 checkDuplicateMessagesOnDuplex=false useBrokerNamesAsIdSeed=true stopping=false suppressDuplicateQueueSubscriptions=true localUri=vm\://broker1?async\=false&network\=true decreaseNetworkConsumerPriority=false suppressDuplicateTopicSubscriptions=true name=test-broker1-to-broker2 } 2016-12-15 10:21:11,654 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: ConnectionInfo {commandId = 2, responseRequired = false, connectionId = broker1->broker2-55990-1481793670235-6:2, clientId = test-broker1-to-broker2_broker1_outbound, clientIp = null, userName = null, password = *****, brokerPath = null, brokerMasterConnector = false, manageable = false, clientMaster = true, faultTolerant = false, failoverReconnect = false} 2016-12-15 10:21:11,655 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: SessionInfo {commandId = 3, responseRequired = false, sessionId = broker1->broker2-55990-1481793670235-6:2:1} 2016-12-15 10:21:11,655 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: ProducerInfo {commandId = 4, responseRequired = false, producerId = broker1->broker2-55990-1481793670235-6:2:1:1, destination = null, brokerPath = null, dispatchAsync = false, windowSize = 0, sentCount = 0} 2016-12-15 10:21:11,656 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: ConsumerInfo {commandId = 5, responseRequired = false, consumerId = broker1->broker2-55990-1481793670235-6:2:1:1, destination = ActiveMQ.Advisory.Consumer.>,ActiveMQ.Advisory.TempQueue,ActiveMQ.Advisory.TempTopic, prefetchSize = 1000, maximumPendingMessageLimit = 0, browser = false, dispatchAsync = true, selector = null, clientId = null, subscriptionName = null, noLocal = false, exclusive = false, retroactive = false, priority = 0, brokerPath = null, optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate = null} 2016-12-15 10:21:15,007 [main ] - WARN NetworkBrokersTest - Starting producer 2016-12-15 10:21:15,008 [Thread-5 ] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-15 10:21:15,009 [Thread-5 ] - DEBUG FailoverTransport - Started unconnected 2016-12-15 10:21:15,009 [Thread-5 ] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-15 10:21:15,010 [ActiveMQ Task-1] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:61626], from: [tcp://localhost:61626] 2016-12-15 10:21:15,010 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:61626 2016-12-15 10:21:15,012 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connection established 2016-12-15 10:21:15,012 [ActiveMQ Task-1] - INFO FailoverTransport - Successfully connected to tcp://localhost:61626 2016-12-15 10:21:15,016 [0.1:61626@56009] - TRACE FailoverTransport - Received ConnectionControl: ConnectionControl {commandId = 0, responseRequired = false, suspend = false, resume = false, close = false, exit = false, faultTolerant = false, connectedBrokers = , reconnectTo = , token = null, rebalanceConnection = false} 2016-12-15 10:21:15,049 [Thread-5 ] - INFO Producer - Sent message: Thread-5 2016-12-15 10:21:17,443 [Thread-4 ] - WARN Consumer - Consumer entering wait loop for messages 2016-12-15 10:21:17,447 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: MessageDispatch {commandId = 0, responseRequired = false, consumerId = broker1->broker2-55990-1481793670235-6:2:1:1, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, message = ActiveMQMessage {commandId = 0, responseRequired = false, messageId = ID:Mac.fritz.box-55990-1481793670235-1:2:0:0:5, originalDestination = null, originalTransactionId = null, producerId = ID:Mac.fritz.box-55990-1481793670235-1:2:0:0, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1481793677439, brokerOutTime = 1481793677443, correlationId = null, replyTo = null, persistent = false, type = Advisory, priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = org.apache.activemq.util.ByteSequence@2b927a99, dataStructure = ConsumerInfo {commandId = 4, responseRequired = true, consumerId = ID:Mac.fritz.box-55990-1481793670235-4:1:1:1, destination = queue://TEST.FOO, prefetchSize = 100, maximumPendingMessageLimit = 0, browser = false, dispatchAsync = true, selector = null, clientId = consumer1, subscriptionName = null, noLocal = false, exclusive = false, retroactive = false, priority = 0, brokerPath = null, optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate = null}, redeliveryCounter = 0, size = 0, properties = {originBrokerName=broker2, originBrokerURL=tcp://Mac.fritz.box:62626, consumerCount=1, originBrokerId=ID:Mac.fritz.box-55990-1481793670235-0:2}, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}, redeliveryCounter = 0} 2016-12-15 10:21:17,450 [127.0.0.1:62616] - DEBUG DemandForwardingBridgeSupport - broker1 new demand subscription: DemandSub{broker1->broker2-55990-1481793670235-6:1:1:1,remotes:[ID:Mac.fritz.box-55990-1481793670235-4:1:1:1]} 2016-12-15 10:21:31,657 [yMonitor Worker] - DEBUG Connection:2 - SENDING: KeepAliveInfo {} 2016-12-15 10:21:31,657 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:21:33,850 [broker1] Task-3] - DEBUG DemandForwardingBridgeSupport - bridging (broker1 -> broker2), consumer: ID:Mac.fritz.box-55990-1481793670235-8:1:1:1:1, destination: broker1->broker2-55990-1481793670235-6:1:1:1, brokerPath: queue://TEST.FOO, message: [ID:Mac.fritz.box-55990-1481793670235-0:1] 2016-12-15 10:21:33,856 [broker1] Task-3] - DEBUG Connection:2 - SENDING: ActiveMQTextMessage {commandId = 6, responseRequired = true, messageId = ID:Mac.fritz.box-55990-1481793670235-8:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = broker1->broker2-55990-1481793670235-6:2:1:1, destination = queue://TEST.FOO, transactionId = null, expiration = 0, timestamp = 1481793693840, arrival = 0, brokerInTime = 1481793693846, brokerOutTime = 1481793693850, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@d770638, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 123866, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false, text = Hello world! From: Thread-5 : 2067868388:0...XXXXXXXXXXXX} 2016-12-15 10:21:41,660 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: KeepAliveInfo {} #tmielke, SQLException manually enforced in debugger 2016-12-15 10:21:44,093 [MQ NIO Worker 2] - WARN JDBCPersistenceAdapter - JDBC Failure: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. java.sql.SQLException: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. at org.apache.commons.dbcp.DelegatingStatement.checkOpen(DelegatingStatement.java:137) at org.apache.commons.dbcp.DelegatingPreparedStatement.setLong(DelegatingPreparedStatement.java:123) at org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doAddMessage(DefaultJDBCAdapter.java:234) at org.apache.activemq.store.jdbc.JDBCMessageStore.addMessage(JDBCMessageStore.java:157) at org.apache.activemq.store.memory.MemoryTransactionStore.addMessage(MemoryTransactionStore.java:352) at org.apache.activemq.store.memory.MemoryTransactionStore$1.asyncAddQueueMessage(MemoryTransactionStore.java:160) at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:830) at org.apache.activemq.broker.region.Queue.send(Queue.java:723) at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:419) at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:468) at org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:296) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:152) at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96) at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:293) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:157) at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:546) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:338) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188) at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:300) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.nio.NIOSSLTransport.doConsume(NIOSSLTransport.java:427) at org.apache.activemq.transport.nio.NIOSSLTransport.processCommand(NIOSSLTransport.java:293) at org.apache.activemq.transport.nio.NIOSSLTransport.serviceRead(NIOSSLTransport.java:208) at org.apache.activemq.transport.nio.NIOSSLTransport$1.onSelect(NIOSSLTransport.java:163) at org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:97) at org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:21:50,892 [MQ NIO Worker 2] - WARN JDBCPersistenceAdapter - Error while closing connection: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. java.sql.SQLException: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. at org.apache.commons.dbcp.DelegatingStatement.checkOpen(DelegatingStatement.java:137) at org.apache.commons.dbcp.DelegatingStatement.executeBatch(DelegatingStatement.java:297) at org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:113) at org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:91) at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:139) at org.apache.activemq.store.jdbc.JDBCMessageStore.addMessage(JDBCMessageStore.java:163) at org.apache.activemq.store.memory.MemoryTransactionStore.addMessage(MemoryTransactionStore.java:352) at org.apache.activemq.store.memory.MemoryTransactionStore$1.asyncAddQueueMessage(MemoryTransactionStore.java:160) at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:830) at org.apache.activemq.broker.region.Queue.send(Queue.java:723) at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:419) at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:468) at org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:296) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:152) at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96) at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:293) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:157) at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:546) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:338) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188) at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:300) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.nio.NIOSSLTransport.doConsume(NIOSSLTransport.java:427) at org.apache.activemq.transport.nio.NIOSSLTransport.processCommand(NIOSSLTransport.java:293) at org.apache.activemq.transport.nio.NIOSSLTransport.serviceRead(NIOSSLTransport.java:208) at org.apache.activemq.transport.nio.NIOSSLTransport$1.onSelect(NIOSSLTransport.java:163) at org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:97) at org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:21:50,894 [MQ NIO Worker 2] - INFO DefaultIOExceptionHandler - Initiating stop/restart of transports on BrokerService[broker2] due to IO exception, java.io.IOException: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. java.io.IOException: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:45) at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:148) at org.apache.activemq.store.jdbc.JDBCMessageStore.addMessage(JDBCMessageStore.java:163) at org.apache.activemq.store.memory.MemoryTransactionStore.addMessage(MemoryTransactionStore.java:352) at org.apache.activemq.store.memory.MemoryTransactionStore$1.asyncAddQueueMessage(MemoryTransactionStore.java:160) at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:830) at org.apache.activemq.broker.region.Queue.send(Queue.java:723) at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:419) at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:468) at org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:296) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:152) at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96) at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:293) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:157) at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:546) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:338) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188) at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:300) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.nio.NIOSSLTransport.doConsume(NIOSSLTransport.java:427) at org.apache.activemq.transport.nio.NIOSSLTransport.processCommand(NIOSSLTransport.java:293) at org.apache.activemq.transport.nio.NIOSSLTransport.serviceRead(NIOSSLTransport.java:208) at org.apache.activemq.transport.nio.NIOSSLTransport$1.onSelect(NIOSSLTransport.java:163) at org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:97) at org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: java.sql.SQLException: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. at org.apache.commons.dbcp.DelegatingStatement.checkOpen(DelegatingStatement.java:137) at org.apache.commons.dbcp.DelegatingStatement.executeBatch(DelegatingStatement.java:297) at org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:113) at org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:91) at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:139) ... 29 more 2016-12-15 10:21:50,899 [0.1:62626@55999] - TRACE FailoverTransport - tcp://localhost:62626 handleTransportFailure: java.io.EOFException java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:21:50,900 [0.1:62626@55999] - WARN FailoverTransport - Transport (tcp://localhost:62626) failed, attempting to automatically reconnect java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:21:50,901 [MQ NIO Worker 2] - INFO TransportConnection - Suppressing reply to: ActiveMQTextMessage {commandId = 6, responseRequired = true, messageId = ID:Mac.fritz.box-55990-1481793670235-8:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = broker1->broker2-55990-1481793670235-6:2:1:1, destination = queue://TEST.FOO, transactionId = null, expiration = 0, timestamp = 1481793693840, arrival = 0, brokerInTime = 1481793693868, brokerOutTime = 1481793693850, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@64dcf5dc, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false, text = Hello world! From: Thread-5 : 2067868388:0...XXXXXXXXXXXX} on: org.apache.activemq.broker.SuppressReplyException: Stop/RestartTransportsInitiated, cause: java.io.IOException: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. 2016-12-15 10:21:50,902 [MQ NIO Worker 2] - WARN Service - Async error occurred: org.apache.activemq.broker.SuppressReplyException: Stop/RestartTransportsInitiated 2016-12-15 10:21:50,903 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:50,904 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 10 ms before attempting connection. #tmielke, transports shutting down 2016-12-15 10:21:50,907 [stop transports] - INFO TransportConnector - Connector openwire4 stopped 2016-12-15 10:21:50,908 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: ConnectionError {commandId = 0, responseRequired = false} 2016-12-15 10:21:50,908 [127.0.0.1:62616] - WARN DemandForwardingBridgeSupport - Network connection between vm://broker1#2 and ssl://localhost:62616?trace=true shutdown due to a remote error: org.apache.activemq.broker.SuppressReplyException: Stop/RestartTransportsInitiated 2016-12-15 10:21:50,908 [127.0.0.1:62616] - DEBUG DemandForwardingBridgeSupport - The remote Exception was: org.apache.activemq.broker.SuppressReplyException: Stop/RestartTransportsInitiated org.apache.activemq.broker.SuppressReplyException: Stop/RestartTransportsInitiated at org.apache.activemq.util.DefaultIOExceptionHandler.handle(DefaultIOExceptionHandler.java:151) at org.apache.activemq.broker.BrokerService.handleIOException(BrokerService.java:2600) at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:149) at org.apache.activemq.store.jdbc.JDBCMessageStore.addMessage(JDBCMessageStore.java:163) at org.apache.activemq.store.memory.MemoryTransactionStore.addMessage(MemoryTransactionStore.java:352) at org.apache.activemq.store.memory.MemoryTransactionStore$1.asyncAddQueueMessage(MemoryTransactionStore.java:160) at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:830) at org.apache.activemq.broker.region.Queue.send(Queue.java:723) at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:419) at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:468) at org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:296) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:152) at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96) at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:293) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:157) at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:546) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:338) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188) at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:300) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.nio.NIOSSLTransport.doConsume(NIOSSLTransport.java:427) at org.apache.activemq.transport.nio.NIOSSLTransport.processCommand(NIOSSLTransport.java:293) at org.apache.activemq.transport.nio.NIOSSLTransport.serviceRead(NIOSSLTransport.java:208) at org.apache.activemq.transport.nio.NIOSSLTransport$1.onSelect(NIOSSLTransport.java:163) at org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:97) at org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.IOException: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:45) at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:148) ... 29 more Caused by: java.sql.SQLException: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@447ffb1: INSERT INTO ACTIVEMQ_MSGS(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **, ** NOT SPECIFIED **)" is closed. at org.apache.commons.dbcp.DelegatingStatement.checkOpen(DelegatingStatement.java:137) at org.apache.commons.dbcp.DelegatingStatement.executeBatch(DelegatingStatement.java:297) at org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:113) at org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:91) at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:139) ... 29 more #bridge stopped 2016-12-15 10:21:50,910 [broker1] Task-3] - DEBUG DemandForwardingBridgeSupport - stopping broker1 bridge to broker2 2016-12-15 10:21:50,911 [ActiveMQ Task-2] - INFO DiscoveryNetworkConnector - Establishing network connection from vm://broker1?async=false&network=true to failover:(ssl://localhost:62616?trace=true,tcp://localhost:61629)?randomize=false&maxReconnectAttempts=0 2016-12-15 10:21:50,911 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: MessageDispatch {commandId = 0, responseRequired = false, consumerId = broker1->broker2-55990-1481793670235-6:2:1:1, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, message = ActiveMQMessage {commandId = 0, responseRequired = false, messageId = ID:Mac.fritz.box-55990-1481793670235-1:2:0:0:6, originalDestination = null, originalTransactionId = null, producerId = ID:Mac.fritz.box-55990-1481793670235-1:2:0:0, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1481793710906, brokerOutTime = 1481793710906, correlationId = null, replyTo = null, persistent = false, type = Advisory, priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = org.apache.activemq.util.ByteSequence@73652138, dataStructure = RemoveInfo {commandId = 0, responseRequired = true, objectId = ID:Mac.fritz.box-55990-1481793670235-4:1:1:1, lastDeliveredSequenceId = -2}, redeliveryCounter = 0, size = 0, properties = {originBrokerName=broker2, originBrokerURL=tcp://Mac.fritz.box:62626, consumerCount=0, originBrokerId=ID:Mac.fritz.box-55990-1481793670235-0:2}, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}, redeliveryCounter = 0} 2016-12-15 10:21:50,911 [ActiveMQ Task-2] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-15 10:21:50,911 [broker1] Task-2] - DEBUG Connection:2 - SENDING: ShutdownInfo {commandId = 7, responseRequired = false} 2016-12-15 10:21:50,912 [stop transports] - INFO TransportConnector - Connector openwire2 stopped 2016-12-15 10:21:50,913 [stop transports] - INFO DefaultIOExceptionHandler - Successfully stopped transports on BrokerService[broker2] 2016-12-15 10:21:50,912 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED Exception: java.io.EOFException java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang.Thread.run(Thread.java:745) #tmielke, failover reconnect fails for a few attempts until broker transport is restarted 2016-12-15 10:21:50,912 [ActiveMQ Task-2] - DEBUG FailoverTransport - Started unconnected 2016-12-15 10:21:50,914 [ActiveMQ Task-2] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-15 10:21:50,914 [127.0.0.1:62616] - TRACE FailoverTransport - ssl://localhost:62616?trace=true handleTransportFailure: java.io.EOFException java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:21:50,913 [broker1] Task-2] - DEBUG FailoverTransport - Send oneway attempt: 0 failed for command:ShutdownInfo {commandId = 7, responseRequired = false} 2016-12-15 10:21:50,915 [broker1] Task-2] - TRACE FailoverTransport - ssl://localhost:62616?trace=true handleTransportFailure: java.net.SocketException: Connection closed by remote host java.net.SocketException: Connection closed by remote host at sun.security.ssl.SSLSocketImpl.checkWrite(SSLSocketImpl.java:1555) at sun.security.ssl.AppOutputStream.write(AppOutputStream.java:71) at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115) at java.io.DataOutputStream.flush(DataOutputStream.java:123) at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:176) at org.apache.activemq.transport.TransportLogger.oneway(TransportLogger.java:104) at org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:334) at org.apache.activemq.transport.AbstractInactivityMonitor.oneway(AbstractInactivityMonitor.java:316) at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85) at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104) at org.apache.activemq.transport.failover.FailoverTransport.oneway(FailoverTransport.java:670) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60) at org.apache.activemq.network.DemandForwardingBridgeSupport$4.run(DemandForwardingBridgeSupport.java:290) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:21:50,916 [ActiveMQ Task-1] - DEBUG FailoverTransport - urlList connectionList:[ssl://localhost:62616?trace=true, tcp://localhost:61629], from: [ssl://localhost:62616?trace=true, tcp://localhost:61629] 2016-12-15 10:21:50,916 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:62626 2016-12-15 10:21:50,916 [broker1] Task-3] - DEBUG FailoverTransport - Stopped ssl://localhost:62616?trace=true 2016-12-15 10:21:50,916 [broker1] Task-3] - INFO DemandForwardingBridgeSupport - broker1 bridge to broker2 stopped 2016-12-15 10:21:50,916 [127.0.0.1:62616] - WARN FailoverTransport - Transport (ssl://localhost:62616?trace=true) failed, not attempting to automatically reconnect java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:21:50,918 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: ssl://localhost:62616?trace=true 2016-12-15 10:21:50,918 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:50,918 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connect fail to: ssl://localhost:62616?trace=true, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:50,918 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 10 ms before attempting connection 2016-12-15 10:21:50,919 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:61629 2016-12-15 10:21:50,920 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:61629, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:50,920 [ActiveMQ Task-1] - ERROR FailoverTransport - Failed to connect to [ssl://localhost:62616?trace=true, tcp://localhost:61629] after: 1 attempt(s) 2016-12-15 10:21:50,928 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:50,929 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 20 ms before attempting connection. 2016-12-15 10:21:50,953 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 1th connect to: tcp://localhost:62626 2016-12-15 10:21:50,953 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:50,954 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 20 ms before attempting connection 2016-12-15 10:21:50,977 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:50,977 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 40 ms before attempting connection. 2016-12-15 10:21:51,021 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 2th connect to: tcp://localhost:62626 2016-12-15 10:21:51,022 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:51,022 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 40 ms before attempting connection 2016-12-15 10:21:51,067 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:51,067 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 80 ms before attempting connection. 2016-12-15 10:21:51,152 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 3th connect to: tcp://localhost:62626 2016-12-15 10:21:51,152 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:51,153 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 80 ms before attempting connection 2016-12-15 10:21:51,234 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:51,235 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 160 ms before attempting connection. 2016-12-15 10:21:51,395 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 4th connect to: tcp://localhost:62626 2016-12-15 10:21:51,396 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:51,396 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 160 ms before attempting connection 2016-12-15 10:21:51,556 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:51,556 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 320 ms before attempting connection. 2016-12-15 10:21:51,878 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 5th connect to: tcp://localhost:62626 2016-12-15 10:21:51,879 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:51,879 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 320 ms before attempting connection 2016-12-15 10:21:52,202 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:52,202 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 640 ms before attempting connection. 2016-12-15 10:21:52,842 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 6th connect to: tcp://localhost:62626 2016-12-15 10:21:52,843 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:52,843 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 640 ms before attempting connection 2016-12-15 10:21:53,486 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:53,486 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 1280 ms before attempting connection. 2016-12-15 10:21:54,769 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 7th connect to: tcp://localhost:62626 2016-12-15 10:21:54,769 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:54,770 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 1280 ms before attempting connection 2016-12-15 10:21:56,050 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:21:56,050 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 2560 ms before attempting connection. 2016-12-15 10:21:58,613 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 8th connect to: tcp://localhost:62626 2016-12-15 10:21:58,614 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-15 10:21:58,614 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 2560 ms before attempting connection 2016-12-15 10:22:01,177 [ActiveMQ Task-3] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-15 10:22:01,177 [ActiveMQ Task-3] - DEBUG FailoverTransport - Waiting 5120 ms before attempting connection. 2016-12-15 10:22:02,464 [tart transports] - INFO TransportServerThreadSupport - Listening for connections at: tcp://Mac.fritz.box:62626?transport.trace=false 2016-12-15 10:22:02,465 [tart transports] - INFO TransportConnector - Connector openwire4 started 2016-12-15 10:22:02,466 [tart transports] - INFO TransportServerThreadSupport - Listening for connections at: nio+ssl://Mac.fritz.box:62616?transport.trace=false 2016-12-15 10:22:02,466 [tart transports] - INFO TransportConnector - Connector openwire2 started 2016-12-15 10:22:02,466 [tart transports] - INFO DefaultIOExceptionHandler - Successfully restarted transports on BrokerService[broker2] 2016-12-15 10:22:04,594 [Thread-5 ] - INFO Producer - Sent message: Thread-5 2016-12-15 10:22:06,301 [ActiveMQ Task-3] - DEBUG FailoverTransport - Attempting 9th connect to: tcp://localhost:62626 2016-12-15 10:22:06,306 [0.1:62626@56025] - TRACE FailoverTransport - Received ConnectionControl: ConnectionControl {commandId = 0, responseRequired = false, suspend = false, resume = false, close = false, exit = false, faultTolerant = false, connectedBrokers = , reconnectTo = , token = null, rebalanceConnection = false} 2016-12-15 10:22:06,306 [ActiveMQ Task-3] - DEBUG FailoverTransport - Connection established 2016-12-15 10:22:06,306 [ActiveMQ Task-3] - INFO FailoverTransport - Successfully reconnected to tcp://localhost:62626 #tmielke, is this part of the problem? Doesn't seem to always show up in customer's log file 2016-12-15 10:22:15,010 [ vm://broker1#4] - INFO DemandForwardingBridgeSupport - Network connection between vm://broker1#4 and unconnected shutdown due to a local error: java.lang.Throwable: remoteBrokerInfo is null 2016-12-15 10:22:15,010 [ vm://broker1#4] - DEBUG DemandForwardingBridgeSupport - The local Exception was: java.lang.Throwable: remoteBrokerInfo is null java.lang.Throwable: remoteBrokerInfo is null at org.apache.activemq.network.DemandForwardingBridgeSupport.collectBrokerInfos(DemandForwardingBridgeSupport.java:351) at org.apache.activemq.network.DemandForwardingBridgeSupport.access$400(DemandForwardingBridgeSupport.java:106) at org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:332) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 2016-12-15 10:22:15,010 [broker1] Task-3] - DEBUG DemandForwardingBridgeSupport - stopping broker1 bridge to Unknown 2016-12-15 10:22:15,011 [ActiveMQ Task-2] - INFO DiscoveryNetworkConnector - Establishing network connection from vm://broker1?async=false&network=true to failover:(ssl://localhost:62616?trace=true,tcp://localhost:61629)?randomize=false&maxReconnectAttempts=0 2016-12-15 10:22:15,011 [broker1] Task-3] - DEBUG FailoverTransport - Stopped unconnected 2016-12-15 10:22:15,011 [ActiveMQ Task-2] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-15 10:22:15,012 [broker1] Task-3] - INFO TransportConnector - Connector vm://broker1 stopped 2016-12-15 10:22:15,012 [broker1] Task-3] - INFO DemandForwardingBridgeSupport - broker1 bridge to Unknown stopped 2016-12-15 10:22:15,012 [ActiveMQ Task-2] - INFO TransportConnector - Connector vm://broker1 started #tmielke, another failover connect 2016-12-15 10:22:15,012 [ActiveMQ Task-2] - DEBUG FailoverTransport - Started unconnected 2016-12-15 10:22:15,012 [ActiveMQ Task-2] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-15 10:22:15,013 [ActiveMQ Task-1] - DEBUG FailoverTransport - urlList connectionList:[ssl://localhost:62616?trace=true, tcp://localhost:61629], from: [ssl://localhost:62616?trace=true, tcp://localhost:61629] 2016-12-15 10:22:15,014 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: ssl://localhost:62616?trace=true #tmielke, we exchange WireFormatInfo but nothing else. 2016-12-15 10:22:15,015 [ActiveMQ Task-1] - DEBUG Connection:4 - SENDING: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 2016-12-15 10:22:15,020 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connection established 2016-12-15 10:22:15,020 [ActiveMQ Task-1] - INFO FailoverTransport - Successfully connected to ssl://localhost:62616?trace=true 2016-12-15 10:22:15,021 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 2016-12-15 10:22:35,024 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} #tmielke, at this stage, the bridge should reconnect. 2016-12-15 10:22:45,025 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:22:55,026 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:22:55,026 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:23:05,031 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:23:05,031 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:23:15,032 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:23:15,032 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:23:25,033 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:23:25,033 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:23:35,037 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:23:35,037 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:23:45,041 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:23:45,041 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} objc[74686]: Class JavaLaunchHelper is implemented in both /Library/Java/JavaVirtualMachines/jdk1.8.0_66.jdk/Contents/Home/bin/java and /Library/Java/JavaVirtualMachines/jdk1.8.0_66.jdk/Contents/Home/jre/lib/libinstrument.dylib. One of the two will be used. Which one is undefined. 2016-12-15 10:23:55,042 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:23:55,043 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:24:05,046 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:24:05,047 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:24:15,049 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:24:15,050 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:24:25,049 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:24:25,050 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:24:35,050 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:24:35,050 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:24:45,054 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:24:45,055 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:24:55,058 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:24:55,058 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:25:05,063 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:25:05,064 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:25:15,064 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:25:15,064 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:25:25,065 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:25:25,066 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:25:35,070 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:25:35,070 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:25:45,074 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:25:45,075 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:25:55,078 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:25:55,079 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:26:05,083 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:26:05,083 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:26:15,083 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:26:15,084 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:26:25,084 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:26:25,085 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-15 10:26:35,089 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-15 10:26:35,089 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {}