2016-12-16 14:45:35,197 [Thread-4 ] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-16 14:45:35,199 [Thread-4 ] - DEBUG FailoverTransport - Started unconnected 2016-12-16 14:45:35,199 [Thread-4 ] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-16 14:45:35,199 [ActiveMQ Task-1] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-16 14:45:35,200 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:62626 2016-12-16 14:45:35,202 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connection established 2016-12-16 14:45:35,203 [ActiveMQ Task-1] - INFO FailoverTransport - Successfully connected to tcp://localhost:62626 2016-12-16 14:45:35,211 [broker2] Task-1] - DEBUG TransportConnection - tmielke: Calling dispatchAsync BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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-16 14:45:35,212 [broker2] Task-2] - DEBUG TransportConnection - tmielke: Sending command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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-16 14:45:35,214 [0.1:65533@62626] - DEBUG TransportConnection - Setting up new connection id: ID:Mac.fritz.box-65524-1481895934431-4:1, address: tcp://127.0.0.1:65533, info: ConnectionInfo {commandId = 1, responseRequired = true, connectionId = ID:Mac.fritz.box-65524-1481895934431-4:1, clientId = consumer1, clientIp = null, userName = null, password = *****, brokerPath = null, brokerMasterConnector = false, manageable = true, clientMaster = true, faultTolerant = true, failoverReconnect = false} 2016-12-16 14:45:35,217 [broker2] Task-2] - DEBUG TransportConnection - tmielke: Sending command: ConnectionControl {commandId = 0, responseRequired = false, suspend = false, resume = false, close = false, exit = false, faultTolerant = false, connectedBrokers = , reconnectTo = , token = null, rebalanceConnection = false} 2016-12-16 14:45:35,217 [0.1:65533@62626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 1} 2016-12-16 14:45:35,217 [0.1:62626@65533] - 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-16 14:45:35,230 [0.1:65533@62626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 2} 2016-12-16 14:45:39,005 [ 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-16 14:45:39,006 [ 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-16 14:45:39,010 [broker1] Task-1] - DEBUG DemandForwardingBridgeSupport - stopping broker1 bridge to Unknown 2016-12-16 14:45:39,014 [broker1] Task-1] - DEBUG FailoverTransport - Stopped unconnected 2016-12-16 14:45:39,014 [broker1] Task-3] - DEBUG TransportConnection - Stopping connection: vm://broker1#0 2016-12-16 14:45:39,014 [broker1] Task-3] - DEBUG TransportConnection - Stopped transport: vm://broker1#0 2016-12-16 14:45:39,014 [broker1] Task-3] - DEBUG TransportConnection - Connection Stopped: vm://broker1#0 2016-12-16 14:45:39,015 [broker1] Task-1] - INFO TransportConnector - Connector vm://broker1 stopped 2016-12-16 14:45:39,015 [broker1] Task-1] - INFO DemandForwardingBridgeSupport - broker1 bridge to Unknown stopped 2016-12-16 14:45:39,189 [main ] - WARN NetworkBrokersTest - Starting producer 2016-12-16 14:45:39,190 [Thread-5 ] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-16 14:45:39,190 [Thread-5 ] - DEBUG FailoverTransport - Started unconnected 2016-12-16 14:45:39,190 [Thread-5 ] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-16 14:45:39,191 [ActiveMQ Task-1] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:61626], from: [tcp://localhost:61626] 2016-12-16 14:45:39,192 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:61626 2016-12-16 14:45:39,192 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connection established 2016-12-16 14:45:39,192 [ActiveMQ Task-1] - INFO FailoverTransport - Successfully connected to tcp://localhost:61626 2016-12-16 14:45:39,194 [broker1] Task-1] - DEBUG TransportConnection - tmielke: Calling dispatchAsync BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-16 14:45:39,195 [broker1] Task-3] - DEBUG TransportConnection - tmielke: Sending command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-16 14:45:39,195 [0.1:65534@61626] - DEBUG TransportConnection - Setting up new connection id: ID:Mac.fritz.box-65524-1481895934431-6:1, address: tcp://127.0.0.1:65534, info: ConnectionInfo {commandId = 1, responseRequired = true, connectionId = ID:Mac.fritz.box-65524-1481895934431-6:1, clientId = ID:Mac.fritz.box-65524-1481895934431-5:1, clientIp = null, userName = null, password = *****, brokerPath = null, brokerMasterConnector = false, manageable = true, clientMaster = true, faultTolerant = true, failoverReconnect = false} 2016-12-16 14:45:39,197 [broker1] Task-3] - DEBUG TransportConnection - tmielke: Sending command: ConnectionControl {commandId = 0, responseRequired = false, suspend = false, resume = false, close = false, exit = false, faultTolerant = false, connectedBrokers = , reconnectTo = , token = null, rebalanceConnection = false} 2016-12-16 14:45:39,197 [0.1:61626@65534] - 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-16 14:45:39,197 [0.1:65534@61626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 1} 2016-12-16 14:45:39,200 [0.1:65534@61626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 2} 2016-12-16 14:45:39,227 [0.1:65534@61626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 4} 2016-12-16 14:45:39,228 [Thread-5 ] - INFO Producer - Sent message: Thread-5 2016-12-16 14:45:40,017 [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-16 14:45:40,017 [ActiveMQ Task-1] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-16 14:45:40,017 [ActiveMQ Task-1] - INFO TransportConnector - Connector vm://broker1 started 2016-12-16 14:45:40,017 [ActiveMQ Task-1] - DEBUG FailoverTransport - Started unconnected 2016-12-16 14:45:40,017 [ActiveMQ Task-1] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-16 14:45:40,018 [broker1] Task-3] - DEBUG TransportConnection - tmielke: Calling dispatchAsync BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-16 14:45:40,018 [broker1] Task-1] - DEBUG TransportConnection - tmielke: Sending command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-16 14:45:40,018 [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-16 14:45:40,020 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: ssl://localhost:62616?trace=true 2016-12-16 14:45:40,022 [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-16 14:45:40,073 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connection established 2016-12-16 14:45:40,073 [ActiveMQ Task-1] - INFO FailoverTransport - Successfully connected to ssl://localhost:62616?trace=true 2016-12-16 14:45:40,075 [broker2] Task-2] - DEBUG TransportConnection - tmielke: Calling dispatchAsync BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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-16 14:45:40,076 [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-16 14:45:40,076 [broker2] Task-1] - DEBUG TransportConnection - tmielke: Sending command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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-16 14:45:40,077 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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-16 14:45:40,535 [0.1:65533@62626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 4} 2016-12-16 14:45:40,535 [Thread-4 ] - WARN Consumer - Consumer entering wait loop for messages 2016-12-16 14:45:43,901 [ vm://broker1#2] - DEBUG TransportConnection - Setting up new connection id: broker1->broker2-65524-1481895934431-8:1, address: vm://broker1#2, info: ConnectionInfo {commandId = 1, responseRequired = true, connectionId = broker1->broker2-65524-1481895934431-8:1, clientId = test-broker1-to-broker2_broker2_inbound_broker1, clientIp = null, userName = null, password = *****, brokerPath = null, brokerMasterConnector = false, manageable = false, clientMaster = true, faultTolerant = false, failoverReconnect = false} 2016-12-16 14:45:43,902 [ vm://broker1#2] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 1} 2016-12-16 14:45:43,907 [ vm://broker1#2] - INFO DemandForwardingBridgeSupport - Network connection between vm://broker1#2 and ssl://localhost:62616?trace=true (broker2) has been established. 2016-12-16 14:45:43,909 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: BrokerInfo {commandId = 1, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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 = # #Fri Dec 16 14:45:43 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-16 14:45:43,910 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: ConnectionInfo {commandId = 2, responseRequired = false, connectionId = broker1->broker2-65524-1481895934431-8: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-16 14:45:43,910 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: SessionInfo {commandId = 3, responseRequired = false, sessionId = broker1->broker2-65524-1481895934431-8:2:1} 2016-12-16 14:45:43,911 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: ProducerInfo {commandId = 4, responseRequired = false, producerId = broker1->broker2-65524-1481895934431-8:2:1:1, destination = null, brokerPath = null, dispatchAsync = false, windowSize = 0, sentCount = 0} 2016-12-16 14:45:43,911 [MQ NIO Worker 2] - DEBUG TransportConnection - Setting up new connection id: broker1->broker2-65524-1481895934431-8:2, address: tcp://127.0.0.1:65535, info: ConnectionInfo {commandId = 2, responseRequired = false, connectionId = broker1->broker2-65524-1481895934431-8: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-16 14:45:43,911 [ vm://broker1#2] - DEBUG Connection:2 - SENDING: ConsumerInfo {commandId = 5, responseRequired = false, consumerId = broker1->broker2-65524-1481895934431-8: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-16 14:45:43,917 [broker2] Task-1] - DEBUG TransportConnection - tmielke: Sending command: MessageDispatch {commandId = 0, responseRequired = false, consumerId = broker1->broker2-65524-1481895934431-8:2:1:1, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, message = ActiveMQMessage {commandId = 0, responseRequired = false, messageId = ID:Mac.fritz.box-65524-1481895934431-1:2:0:0:7, originalDestination = null, originalTransactionId = null, producerId = ID:Mac.fritz.box-65524-1481895934431-1:2:0:0, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1481895943914, brokerOutTime = 1481895943916, correlationId = null, replyTo = null, persistent = false, type = Advisory, priority = 0, groupID = null, groupSequence = 0, targetConsumerId = broker1->broker2-65524-1481895934431-8:2:1:1, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = ConsumerInfo {commandId = 4, responseRequired = true, consumerId = ID:Mac.fritz.box-65524-1481895934431-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 = 1024, properties = {originBrokerURL=tcp://Mac.fritz.box:62626, consumerCount=1, originBrokerId=ID:Mac.fritz.box-65524-1481895934431-0:2, originBrokerName=broker2}, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}, redeliveryCounter = 0} 2016-12-16 14:45:43,920 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: MessageDispatch {commandId = 0, responseRequired = false, consumerId = broker1->broker2-65524-1481895934431-8:2:1:1, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, message = ActiveMQMessage {commandId = 0, responseRequired = false, messageId = ID:Mac.fritz.box-65524-1481895934431-1:2:0:0:7, originalDestination = null, originalTransactionId = null, producerId = ID:Mac.fritz.box-65524-1481895934431-1:2:0:0, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1481895943914, brokerOutTime = 1481895943916, correlationId = null, replyTo = null, persistent = false, type = Advisory, priority = 0, groupID = null, groupSequence = 0, targetConsumerId = broker1->broker2-65524-1481895934431-8:2:1:1, compressed = false, userID = null, content = null, marshalledProperties = org.apache.activemq.util.ByteSequence@9112cc9, dataStructure = ConsumerInfo {commandId = 4, responseRequired = true, consumerId = ID:Mac.fritz.box-65524-1481895934431-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-65524-1481895934431-0:2}, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}, redeliveryCounter = 0} 2016-12-16 14:45:43,924 [127.0.0.1:62616] - DEBUG DemandForwardingBridgeSupport - broker1 new demand subscription: DemandSub{broker1->broker2-65524-1481895934431-8:1:1:1,remotes:[ID:Mac.fritz.box-65524-1481895934431-4:1:1:1]} 2016-12-16 14:45:51,257 [0.1:65534@61626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 5} 2016-12-16 14:45:51,264 [broker1] Task-1] - DEBUG TransportConnection - tmielke: Sending command: MessageDispatch {commandId = 0, responseRequired = false, consumerId = broker1->broker2-65524-1481895934431-8:1:1:1, destination = queue://TEST.FOO, message = ActiveMQTextMessage {commandId = 5, responseRequired = true, messageId = ID:Mac.fritz.box-65524-1481895934431-6:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:Mac.fritz.box-65524-1481895934431-6:1:1:1, destination = queue://TEST.FOO, transactionId = null, expiration = 0, timestamp = 1481895951246, arrival = 0, brokerInTime = 1481895951254, brokerOutTime = 1481895951259, 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@53807219, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 123866, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false, text = Hello world! From: Thread-5 : 2055888490:0...XXXXXXXXXXXX}, redeliveryCounter = 0} 2016-12-16 14:45:51,264 [broker1] Task-1] - DEBUG DemandForwardingBridgeSupport - bridging (broker1 -> broker2), consumer: ID:Mac.fritz.box-65524-1481895934431-6:1:1:1:1, destination: broker1->broker2-65524-1481895934431-8:1:1:1, brokerPath: queue://TEST.FOO, message: [ID:Mac.fritz.box-65524-1481895934431-0:1] 2016-12-16 14:45:51,267 [broker1] Task-1] - DEBUG Connection:2 - SENDING: ActiveMQTextMessage {commandId = 6, responseRequired = true, messageId = ID:Mac.fritz.box-65524-1481895934431-6:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = broker1->broker2-65524-1481895934431-8:2:1:1, destination = queue://TEST.FOO, transactionId = null, expiration = 0, timestamp = 1481895951246, arrival = 0, brokerInTime = 1481895951254, brokerOutTime = 1481895951259, 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@53807219, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 123866, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false, text = Hello world! From: Thread-5 : 2055888490:0...XXXXXXXXXXXX} 2016-12-16 14:45:58,397 [MQ NIO Worker 2] - WARN JDBCPersistenceAdapter - JDBC Failure: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@7680916a: 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@7680916a: 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-16 14:46:00,083 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: KeepAliveInfo {} 2016-12-16 14:46:03,620 [MQ NIO Worker 2] - WARN JDBCPersistenceAdapter - Error while closing connection: org.apache.commons.dbcp.DelegatingPreparedStatement with address: "com.mysql.jdbc.JDBC4PreparedStatement@7680916a: 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@7680916a: 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-16 14:46:03,621 [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@7680916a: 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@7680916a: 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@7680916a: 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-16 14:46:03,623 [broker2] Task-1] - DEBUG TransportConnection - Stopping connection: tcp://127.0.0.1:65533 2016-12-16 14:46:03,624 [0.1:62626@65533] - 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-16 14:46:03,624 [broker2] Task-1] - DEBUG TransportConnection - Stopped transport: tcp://127.0.0.1:65533 2016-12-16 14:46:03,625 [broker2] Task-1] - DEBUG TransportConnection - Cleaning up connection resources: tcp://127.0.0.1:65533 2016-12-16 14:46:03,625 [broker2] Task-1] - DEBUG TransportConnection - remove connection id: ID:Mac.fritz.box-65524-1481895934431-4:1 2016-12-16 14:46:03,625 [0.1:62626@65533] - 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-16 14:46:03,626 [MQ NIO Worker 2] - DEBUG Service - Error occured while processing sync command: ActiveMQTextMessage {commandId = 6, responseRequired = true, messageId = ID:Mac.fritz.box-65524-1481895934431-6:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = broker1->broker2-65524-1481895934431-8:2:1:1, destination = queue://TEST.FOO, transactionId = null, expiration = 0, timestamp = 1481895951246, arrival = 0, brokerInTime = 1481895951281, brokerOutTime = 1481895951259, 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@344ad7c9, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false, text = Hello world! From: Thread-5 : 2055888490:0...XXXXXXXXXXXX}, exception: 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@7680916a: 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@7680916a: 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-16 14:46:03,627 [ActiveMQ Task-2] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-16 14:46:03,627 [ActiveMQ Task-2] - DEBUG FailoverTransport - Waiting 10 ms before attempting connection. 2016-12-16 14:46:03,628 [MQ NIO Worker 2] - INFO TransportConnection - Suppressing reply to: ActiveMQTextMessage {commandId = 6, responseRequired = true, messageId = ID:Mac.fritz.box-65524-1481895934431-6:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = broker1->broker2-65524-1481895934431-8:2:1:1, destination = queue://TEST.FOO, transactionId = null, expiration = 0, timestamp = 1481895951246, arrival = 0, brokerInTime = 1481895951281, brokerOutTime = 1481895951259, 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@344ad7c9, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false, text = Hello world! From: Thread-5 : 2055888490: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@7680916a: 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-16 14:46:03,629 [MQ NIO Worker 2] - DEBUG Service - Async error occurred: 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@7680916a: 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@7680916a: 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-16 14:46:03,630 [broker2] Task-2] - DEBUG TransportConnection - tmielke: Sending command: ConnectionError {commandId = 0, responseRequired = false} 2016-12-16 14:46:03,632 [broker2] Task-1] - DEBUG TransportConnection - Connection Stopped: tcp://127.0.0.1:65533 2016-12-16 14:46:03,632 [stop transports] - INFO TransportConnector - Connector openwire4 stopped 2016-12-16 14:46:03,633 [broker2] Task-2] - DEBUG TransportConnection - tmielke: Sending command: MessageDispatch {commandId = 0, responseRequired = false, consumerId = broker1->broker2-65524-1481895934431-8:2:1:1, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, message = ActiveMQMessage {commandId = 0, responseRequired = false, messageId = ID:Mac.fritz.box-65524-1481895934431-1:2:0:0:8, originalDestination = null, originalTransactionId = null, producerId = ID:Mac.fritz.box-65524-1481895934431-1:2:0:0, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1481895963630, brokerOutTime = 1481895963633, correlationId = null, replyTo = null, persistent = false, type = Advisory, priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = RemoveInfo {commandId = 0, responseRequired = true, objectId = ID:Mac.fritz.box-65524-1481895934431-4:1:1:1, lastDeliveredSequenceId = -2}, redeliveryCounter = 0, size = 1024, properties = {originBrokerURL=tcp://Mac.fritz.box:62626, consumerCount=0, originBrokerId=ID:Mac.fritz.box-65524-1481895934431-0:2, originBrokerName=broker2}, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}, redeliveryCounter = 0} 2016-12-16 14:46:03,635 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: ConnectionError {commandId = 0, responseRequired = false} 2016-12-16 14:46:03,635 [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-16 14:46:03,635 [broker2] Task-1] - DEBUG TransportConnection - Stopping connection: tcp://127.0.0.1:65535 2016-12-16 14:46:03,635 [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@7680916a: 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@7680916a: 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-16 14:46:03,636 [broker2] Task-1] - DEBUG TransportConnection - Stopped transport: null 2016-12-16 14:46:03,636 [broker2] Task-1] - DEBUG TransportConnection - Cleaning up connection resources: null 2016-12-16 14:46:03,636 [broker2] Task-1] - DEBUG TransportConnection - remove connection id: broker1->broker2-65524-1481895934431-8:2 2016-12-16 14:46:03,637 [broker2] Task-1] - DEBUG TransportConnection - Connection Stopped: null 2016-12-16 14:46:03,637 [stop transports] - INFO TransportConnector - Connector openwire2 stopped 2016-12-16 14:46:03,638 [stop transports] - INFO DefaultIOExceptionHandler - Successfully stopped transports on BrokerService[broker2] 2016-12-16 14:46:03,638 [broker1] Task-1] - DEBUG DemandForwardingBridgeSupport - stopping broker1 bridge to broker2 2016-12-16 14:46:03,638 [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-16 14:46:03,639 [ActiveMQ Task-1] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-16 14:46:03,639 [ActiveMQ Task-2] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:62626 2016-12-16 14:46:03,639 [127.0.0.1:62616] - DEBUG Connection:2 - RECEIVED: MessageDispatch {commandId = 0, responseRequired = false, consumerId = broker1->broker2-65524-1481895934431-8:2:1:1, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, message = ActiveMQMessage {commandId = 0, responseRequired = false, messageId = ID:Mac.fritz.box-65524-1481895934431-1:2:0:0:8, originalDestination = null, originalTransactionId = null, producerId = ID:Mac.fritz.box-65524-1481895934431-1:2:0:0, destination = topic://ActiveMQ.Advisory.Consumer.Queue.TEST.FOO, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1481895963630, brokerOutTime = 1481895963633, 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@7c75cbd8, dataStructure = RemoveInfo {commandId = 0, responseRequired = true, objectId = ID:Mac.fritz.box-65524-1481895934431-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-65524-1481895934431-0:2}, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}, redeliveryCounter = 0} 2016-12-16 14:46:03,639 [ActiveMQ Task-1] - DEBUG FailoverTransport - Started unconnected 2016-12-16 14:46:03,639 [ActiveMQ Task-1] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-16 14:46:03,640 [ActiveMQ Task-2] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:62626, reason: java.net.ConnectException: Connection refused 2016-12-16 14:46:03,641 [broker1] Task-4] - DEBUG TransportConnection - Stopping connection: vm://broker1#2 2016-12-16 14:46:03,640 [broker1] Task-3] - DEBUG Connection:2 - SENDING: ShutdownInfo {commandId = 7, responseRequired = false} 2016-12-16 14:46:03,640 [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-16 14:46:03,641 [broker1] Task-3] - DEBUG FailoverTransport - Send oneway attempt: 0 failed for command:ShutdownInfo {commandId = 7, responseRequired = false} 2016-12-16 14:46:03,640 [broker1] Task-2] - DEBUG TransportConnection - tmielke: Calling dispatchAsync BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-16 14:46:03,640 [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) 2016-12-16 14:46:03,642 [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-16 14:46:03,641 [broker1] Task-4] - DEBUG TransportConnection - Stopped transport: vm://broker1#2 2016-12-16 14:46:03,642 [broker1] Task-4] - DEBUG TransportConnection - Cleaning up connection resources: vm://broker1#2 2016-12-16 14:46:03,642 [broker1] Task-4] - DEBUG TransportConnection - remove connection id: broker1->broker2-65524-1481895934431-8:1 2016-12-16 14:46:03,642 [ActiveMQ Task-2] - DEBUG FailoverTransport - Waiting 10 ms before attempting connection 2016-12-16 14:46:03,641 [broker1] Task-3] - 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-16 14:46:03,644 [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-16 14:46:03,644 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: ssl://localhost:62616?trace=true 2016-12-16 14:46:03,645 [broker1] Task-1] - DEBUG FailoverTransport - Stopped unconnected 2016-12-16 14:46:03,645 [broker1] Task-6] - DEBUG TransportConnection - tmielke: Sending command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-16 14:46:03,645 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connect fail to: ssl://localhost:62616?trace=true, reason: java.net.ConnectException: Connection refused 2016-12-16 14:46:03,646 [broker1] Task-4] - DEBUG TransportConnection - Connection Stopped: vm://broker1#2 2016-12-16 14:46:03,647 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: tcp://localhost:61629 2016-12-16 14:46:03,647 [broker1] Task-1] - INFO DemandForwardingBridgeSupport - broker1 bridge to broker2 stopped 2016-12-16 14:46:03,647 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connect fail to: tcp://localhost:61629, reason: java.net.ConnectException: Connection refused 2016-12-16 14:46:03,648 [ActiveMQ Task-1] - ERROR FailoverTransport - Failed to connect to [ssl://localhost:62616?trace=true, tcp://localhost:61629] after: 1 attempt(s) 2016-12-16 14:46:03,649 [tart transports] - INFO TransportServerThreadSupport - Listening for connections at: tcp://Mac.fritz.box:62626?transport.trace=false 2016-12-16 14:46:03,649 [tart transports] - INFO TransportConnector - Connector openwire4 started 2016-12-16 14:46:03,650 [tart transports] - INFO TransportServerThreadSupport - Listening for connections at: nio+ssl://Mac.fritz.box:62616?transport.trace=false 2016-12-16 14:46:03,650 [tart transports] - INFO TransportConnector - Connector openwire2 started 2016-12-16 14:46:03,650 [tart transports] - INFO DefaultIOExceptionHandler - Successfully restarted transports on BrokerService[broker2] 2016-12-16 14:46:03,653 [ActiveMQ Task-2] - DEBUG FailoverTransport - urlList connectionList:[tcp://localhost:62626], from: [tcp://localhost:62626] 2016-12-16 14:46:03,653 [ActiveMQ Task-2] - DEBUG FailoverTransport - Waiting 20 ms before attempting connection. 2016-12-16 14:46:03,678 [ActiveMQ Task-2] - DEBUG FailoverTransport - Attempting 1th connect to: tcp://localhost:62626 2016-12-16 14:46:03,680 [broker2] Task-1] - DEBUG TransportConnection - tmielke: Calling dispatchAsync BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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-16 14:46:03,680 [broker2] Task-2] - DEBUG TransportConnection - tmielke: Sending command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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-16 14:46:03,681 [0.1:49160@62626] - DEBUG TransportConnection - Setting up new connection id: ID:Mac.fritz.box-65524-1481895934431-4:1, address: tcp://127.0.0.1:49160, info: ConnectionInfo {commandId = 1, responseRequired = true, connectionId = ID:Mac.fritz.box-65524-1481895934431-4:1, clientId = consumer1, clientIp = null, userName = null, password = *****, brokerPath = null, brokerMasterConnector = false, manageable = true, clientMaster = true, faultTolerant = true, failoverReconnect = true} 2016-12-16 14:46:03,681 [broker2] Task-2] - DEBUG TransportConnection - tmielke: Sending command: ConnectionControl {commandId = 0, responseRequired = false, suspend = false, resume = false, close = false, exit = false, faultTolerant = false, connectedBrokers = , reconnectTo = , token = null, rebalanceConnection = false} 2016-12-16 14:46:03,681 [ActiveMQ Task-2] - DEBUG FailoverTransport - Connection established 2016-12-16 14:46:03,682 [ActiveMQ Task-2] - INFO FailoverTransport - Successfully reconnected to tcp://localhost:62626 2016-12-16 14:46:03,681 [0.1:62626@49160] - 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-16 14:46:03,682 [0.1:49160@62626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 1} 2016-12-16 14:46:03,683 [0.1:49160@62626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 4} 2016-12-16 14:46:03,684 [0.1:49160@62626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 2} 2016-12-16 14:46:09,483 [ 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-16 14:46:09,483 [ 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-16 14:46:09,484 [broker1] Task-1] - DEBUG DemandForwardingBridgeSupport - stopping broker1 bridge to Unknown 2016-12-16 14:46:09,484 [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-16 14:46:09,484 [broker1] Task-4] - DEBUG TransportConnection - Stopping connection: vm://broker1#4 2016-12-16 14:46:09,484 [broker1] Task-1] - DEBUG FailoverTransport - Stopped unconnected 2016-12-16 14:46:09,484 [broker1] Task-4] - DEBUG TransportConnection - Stopped transport: vm://broker1#4 2016-12-16 14:46:09,484 [ActiveMQ Task-1] - DEBUG FailoverTransport - Reconnect was triggered but transport is not started yet. Wait for start to connect the transport. 2016-12-16 14:46:09,485 [broker1] Task-4] - DEBUG TransportConnection - Connection Stopped: vm://broker1#4 2016-12-16 14:46:09,485 [broker1] Task-1] - INFO DemandForwardingBridgeSupport - broker1 bridge to Unknown stopped 2016-12-16 14:46:09,485 [broker1] Task-4] - DEBUG TransportConnection - tmielke: Calling dispatchAsync BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-16 14:46:09,486 [ActiveMQ Task-1] - DEBUG FailoverTransport - Started unconnected 2016-12-16 14:46:09,486 [ActiveMQ Task-1] - DEBUG FailoverTransport - Waking up reconnect task 2016-12-16 14:46:09,486 [broker1] Task-1] - DEBUG TransportConnection - tmielke: Sending command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-0:1, brokerURL = tcp://Mac.fritz.box:61626, slaveBroker = false, masterBroker = false, faultTolerantConfiguration = false, networkConnection = false, duplexConnection = false, peerBrokerInfos = null, brokerName = broker1, connectionId = 0, brokerUploadUrl = null, networkProperties = null} 2016-12-16 14:46:09,486 [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-16 14:46:09,488 [ActiveMQ Task-1] - DEBUG FailoverTransport - Attempting 0th connect to: ssl://localhost:62616?trace=true 2016-12-16 14:46:09,490 [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-16 14:46:09,495 [ActiveMQ Task-1] - DEBUG FailoverTransport - Connection established 2016-12-16 14:46:09,495 [ActiveMQ Task-1] - INFO FailoverTransport - Successfully connected to ssl://localhost:62616?trace=true 2016-12-16 14:46:09,495 [broker2] Task-2] - DEBUG TransportConnection - tmielke: Calling dispatchAsync BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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-16 14:46:09,495 [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-16 14:46:09,496 [broker2] Task-1] - DEBUG TransportConnection - tmielke: Sending command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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} #tmielke 2016-12-16 14:46:19,497 [broker2] Task-1] - ERROR TransportConnection - tmielke: Error dispatching command: BrokerInfo {commandId = 0, responseRequired = false, brokerId = ID:Mac.fritz.box-65524-1481895934431-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} java.io.IOException: Wire format negotiation timeout: peer did not send his wire format. at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:98) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1435) at org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:947) at org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:994) at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133) at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48) 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-16 14:46:29,499 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-16 14:46:39,499 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-16 14:46:41,341 [Thread-5 ] - INFO Producer - Sent message: Thread-5 2016-12-16 14:46:41,721 [0.1:65534@61626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 6} 2016-12-16 14:46:43,596 [0.1:65534@61626] - DEBUG TransportConnection - remove connection id: ID:Mac.fritz.box-65524-1481895934431-6:1 2016-12-16 14:46:43,596 [0.1:65534@61626] - DEBUG TransportConnection - tmielke: Sending command: Response {commandId = 0, responseRequired = false, correlationId = 10} 2016-12-16 14:46:43,597 [broker1] Task-4] - DEBUG TransportConnection - Stopping connection: tcp://127.0.0.1:65534 2016-12-16 14:46:43,598 [Thread-5 ] - DEBUG FailoverTransport - Stopped tcp://localhost:61626 2016-12-16 14:46:43,598 [broker1] Task-4] - DEBUG TransportConnection - Stopped transport: tcp://127.0.0.1:65534 2016-12-16 14:46:43,598 [broker1] Task-4] - DEBUG TransportConnection - Connection Stopped: tcp://127.0.0.1:65534 2016-12-16 14:46:49,504 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-16 14:46:49,504 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} objc[78478]: 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-16 14:46:59,505 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-16 14:46:59,505 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {} 2016-12-16 14:47:09,510 [yMonitor Worker] - DEBUG Connection:4 - SENDING: KeepAliveInfo {} 2016-12-16 14:47:09,510 [127.0.0.1:62616] - DEBUG Connection:4 - RECEIVED: KeepAliveInfo {}