I will try to send you the unitary tests, however I have additional logbooks
hereafter.
Really confusing myself...It occurs after 50 successive calls when using
half duplex in between the two brokers. If I switch to only one DUPLEX, it's
fine.
===================
THIS ONE IS FINE
===================
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 removing
consumer: ID:PC710618-49374-1554792737713-11:1:194:1 for destination:
topic://ACK
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed interest for: ID:PC710618-49374-1554792737713-11:1:194:1
from DemandSub{broker1->broker2-49374-1554792737713-7:1:1:194,remotes:[]}
8989 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:194,remotes:[]}
8989 [pool-1-thread-1] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker1 removing
consumer: broker1->broker2-49374-1554792737713-7:1:1:194 for destination:
topic://ACK
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [pool-1-thread-1] DEBUG org.apache.activemq.broker.TransportConnector
- Publishing: vm://broker1 for broker transport URI: vm://broker1
8989 [pool-1-thread-1] DEBUG org.apache.activemq.broker.TransportConnector
- Publishing: vm://broker1 for broker transport URI: vm://broker1
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 adding consumer:
ID:PC710618-49374-1554792737713-11:1:195:1 for destination: topic://ACK
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker1 adding consumer:
broker1->broker2-49374-1554792737713-7:1:1:195 for destination: topic://ACK
8989 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing: vm://broker1
for broker transport URI: vm://broker1
8989 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing: vm://broker1
for broker transport URI: vm://broker1
8989 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - broker1 new
demand subscription:
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:195,remotes:[ID:PC710618-49374-1554792737713-11:1:195:1]}
8989 [ActiveMQ BrokerService[broker2] Task-2] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - bridging
(broker2 -> broker1), consumer:
broker2->broker1-49374-1554792737713-6:1:1:1, destination:
topic://TEST_TOPIC, brokerPath: [ID:PC710618-49374-1554792737713-0:2],
message: ID:PC710618-49374-1554792737713-11:1:195:1:1
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
8989 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9005 [ActiveMQ BrokerService[broker1] Task-2] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - bridging
(broker1 -> broker2), consumer:
broker1->broker2-49374-1554792737713-7:1:1:195, destination: topic://ACK,
brokerPath: [ID:PC710618-49374-1554792737713-0:1], message:
ID:PC710618-49374-1554792737713-9:1:1:195:1
9005 [ActiveMQ Transport: tcp:///127.0.0.1:50001@49376] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - broker2
Ignoring sub from broker1, restricted to 1 network hops only: ConsumerInfo
{commandId = 584, responseRequired = false, consumerId =
broker1->broker2-49374-1554792737713-7:1:1:195, destination = topic://ACK,
prefetchSize = 1000, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = true, selector = null, clientId =
ID:PC710618-49374-1554792737713-10:1, subscriptionName = null, noLocal =
false, exclusive = false, retroactive = false, priority = 0, brokerPath =
[ID:PC710618-49374-1554792737713-0:2], optimizedAcknowledge = false,
noRangeAcks = false, additionalPredicate =
org.apache.activemq.command.NetworkBridgeFilter@32953d81, networkConsumerIds
= [ID:PC710618-49374-1554792737713-11:1:195:1]}
9005 [main] DEBUG org.apache.activemq.ActiveMQMessageConsumer - remove:
ID:PC710618-49374-1554792737713-11:1:195:1, lastDeliveredSequenceId: 1174
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 removing
consumer: ID:PC710618-49374-1554792737713-11:1:195:1 for destination:
topic://ACK
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
===================
THIS ONE IS FINE
===================
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9005 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed interest for: ID:PC710618-49374-1554792737713-11:1:195:1
from DemandSub{broker1->broker2-49374-1554792737713-7:1:1:195,remotes:[]}
9005 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:195,remotes:[]}
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9005 [pool-1-thread-1] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker1 removing
consumer: broker1->broker2-49374-1554792737713-7:1:1:195 for destination:
topic://ACK
9005 [pool-1-thread-1] DEBUG org.apache.activemq.broker.TransportConnector
- Publishing: vm://broker1 for broker transport URI: vm://broker1
9005 [pool-1-thread-1] DEBUG org.apache.activemq.broker.TransportConnector
- Publishing: vm://broker1 for broker transport URI: vm://broker1
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 adding consumer:
ID:PC710618-49374-1554792737713-11:1:196:1 for destination: topic://ACK
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9005 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9005 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker1 adding consumer:
broker1->broker2-49374-1554792737713-7:1:1:196 for destination: topic://ACK
9005 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing: vm://broker1
for broker transport URI: vm://broker1
9005 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing: vm://broker1
for broker transport URI: vm://broker1
9005 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - broker1 new
demand subscription:
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:196,remotes:[ID:PC710618-49374-1554792737713-11:1:196:1]}
9005 [ActiveMQ Transport: tcp:///127.0.0.1:50001@49376] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - broker2
Ignoring sub from broker1, restricted to 1 network hops only: ConsumerInfo
{commandId = 587, responseRequired = false, consumerId =
broker1->broker2-49374-1554792737713-7:1:1:196, destination = topic://ACK,
prefetchSize = 1000, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = true, selector = null, clientId =
ID:PC710618-49374-1554792737713-10:1, subscriptionName = null, noLocal =
false, exclusive = false, retroactive = false, priority = 0, brokerPath =
[ID:PC710618-49374-1554792737713-0:2], optimizedAcknowledge = false,
noRangeAcks = false, additionalPredicate =
org.apache.activemq.command.NetworkBridgeFilter@915f04d, networkConsumerIds
= [ID:PC710618-49374-1554792737713-11:1:196:1]}
9020 [ActiveMQ BrokerService[broker2] Task-2] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - bridging
(broker2 -> broker1), consumer:
broker2->broker1-49374-1554792737713-6:1:1:1, destination:
topic://TEST_TOPIC, brokerPath: [ID:PC710618-49374-1554792737713-0:2],
message: ID:PC710618-49374-1554792737713-11:1:196:1:1
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ BrokerService[broker1] Task-3] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - bridging
(broker1 -> broker2), consumer:
broker1->broker2-49374-1554792737713-7:1:1:196, destination: topic://ACK,
brokerPath: [ID:PC710618-49374-1554792737713-0:1], message:
ID:PC710618-49374-1554792737713-9:1:1:196:1
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [main] DEBUG org.apache.activemq.ActiveMQMessageConsumer - remove:
ID:PC710618-49374-1554792737713-11:1:196:1, lastDeliveredSequenceId: 1180
===================
THIS ONE IS FINE
===================
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 removing
consumer: ID:PC710618-49374-1554792737713-11:1:196:1 for destination:
topic://ACK
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed interest for: ID:PC710618-49374-1554792737713-11:1:196:1
from DemandSub{broker1->broker2-49374-1554792737713-7:1:1:196,remotes:[]}
9020 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:196,remotes:[]}
9020 [pool-1-thread-1] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker1 removing
consumer: broker1->broker2-49374-1554792737713-7:1:1:196 for destination:
topic://ACK
9020 [pool-1-thread-1] DEBUG org.apache.activemq.broker.TransportConnector
- Publishing: vm://broker1 for broker transport URI: vm://broker1
9020 [pool-1-thread-1] DEBUG org.apache.activemq.broker.TransportConnector
- Publishing: vm://broker1 for broker transport URI: vm://broker1
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 adding consumer:
ID:PC710618-49374-1554792737713-11:1:197:1 for destination: topic://ACK
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ BrokerService[broker2] Task-3] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - bridging
(broker2 -> broker1), consumer:
broker2->broker1-49374-1554792737713-6:1:1:1, destination:
topic://TEST_TOPIC, brokerPath: [ID:PC710618-49374-1554792737713-0:2],
message: ID:PC710618-49374-1554792737713-11:1:197:1:1
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
9020 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker1 adding consumer:
broker1->broker2-49374-1554792737713-7:1:1:197 for destination: topic://ACK
9020 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing: vm://broker1
for broker transport URI: vm://broker1
9020 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing: vm://broker1
for broker transport URI: vm://broker1
9020 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - broker1 new
demand subscription:
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:197,remotes:[ID:PC710618-49374-1554792737713-11:1:197:1]}
9020 [ActiveMQ Transport: tcp:///127.0.0.1:50001@49376] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - broker2
Ignoring sub from broker1, restricted to 1 network hops only: ConsumerInfo
{commandId = 590, responseRequired = false, consumerId =
broker1->broker2-49374-1554792737713-7:1:1:197, destination = topic://ACK,
prefetchSize = 1000, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = true, selector = null, clientId =
ID:PC710618-49374-1554792737713-10:1, subscriptionName = null, noLocal =
false, exclusive = false, retroactive = false, priority = 0, brokerPath =
[ID:PC710618-49374-1554792737713-0:2], optimizedAcknowledge = false,
noRangeAcks = false, additionalPredicate =
org.apache.activemq.command.NetworkBridgeFilter@32eaa782, networkConsumerIds
= [ID:PC710618-49374-1554792737713-11:1:197:1]}
11033 [main] DEBUG org.apache.activemq.ActiveMQMessageConsumer - remove:
ID:PC710618-49374-1554792737713-11:1:197:1, lastDeliveredSequenceId: -1
>>>>>>>>>>>>>>>>>>>>>
ERROR OCCURED : A runtime exception occurred during the method invocation.
<<<<<<<<<<<<<<<<<<<<<
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 removing
consumer: ID:PC710618-49374-1554792737713-11:1:197:1 for destination:
topic://ACK
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11033 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed interest for: ID:PC710618-49374-1554792737713-11:1:197:1
from DemandSub{broker1->broker2-49374-1554792737713-7:1:1:197,remotes:[]}
11033 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:197,remotes:[]}
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 adding consumer:
ID:PC710618-49374-1554792737713-11:1:198:1 for destination: topic://ACK
11033 [pool-1-thread-1] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker1 removing
consumer: broker1->broker2-49374-1554792737713-7:1:1:197 for destination:
topic://ACK
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11033 [ActiveMQ BrokerService[broker2] Task-2] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - bridging
(broker2 -> broker1), consumer:
broker2->broker1-49374-1554792737713-6:1:1:1, destination:
topic://TEST_TOPIC, brokerPath: [ID:PC710618-49374-1554792737713-0:2],
message: ID:PC710618-49374-1554792737713-11:1:198:1:1
11033 [pool-1-thread-1] DEBUG org.apache.activemq.broker.TransportConnector
- Publishing: vm://broker1 for broker transport URI: vm://broker1
11033 [pool-1-thread-1] DEBUG org.apache.activemq.broker.TransportConnector
- Publishing: vm://broker1 for broker transport URI: vm://broker1
11033 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker1 adding consumer:
broker1->broker2-49374-1554792737713-7:1:1:198 for destination: topic://ACK
11033 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing: vm://broker1
for broker transport URI: vm://broker1
11034 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing: vm://broker1
for broker transport URI: vm://broker1
11034 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - broker1 new
demand subscription:
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:198,remotes:[ID:PC710618-49374-1554792737713-11:1:198:1]}
11033 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11034 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11034 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11034 [ActiveMQ Transport: tcp:///127.0.0.1:49377@50001] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50001 for broker transport URI:
tcp://PC710618:50001?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11034 [ActiveMQ BrokerService[broker1] Task-2] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - bridging
(broker1 -> broker2), consumer:
broker1->broker2-49374-1554792737713-7:1:1:198, destination: topic://ACK,
brokerPath: [ID:PC710618-49374-1554792737713-0:1], message:
ID:PC710618-49374-1554792737713-9:1:1:198:1
11065 [ActiveMQ Transport: tcp:///127.0.0.1:50001@49376] DEBUG
org.apache.activemq.network.DemandForwardingBridgeSupport - broker2
Ignoring sub from broker1, restricted to 1 network hops only: ConsumerInfo
{commandId = 592, responseRequired = false, consumerId =
broker1->broker2-49374-1554792737713-7:1:1:198, destination = topic://ACK,
prefetchSize = 1000, maximumPendingMessageLimit = 0, browser = false,
dispatchAsync = true, selector = null, clientId =
ID:PC710618-49374-1554792737713-10:1, subscriptionName = null, noLocal =
false, exclusive = false, retroactive = false, priority = 0, brokerPath =
[ID:PC710618-49374-1554792737713-0:2], optimizedAcknowledge = false,
noRangeAcks = false, additionalPredicate =
org.apache.activemq.command.NetworkBridgeFilter@448fea81, networkConsumerIds
= [ID:PC710618-49374-1554792737713-11:1:198:1]}
11065 [main] DEBUG org.apache.activemq.ActiveMQMessageConsumer - remove:
ID:PC710618-49374-1554792737713-11:1:198:1, lastDeliveredSequenceId: 1191
11065 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.region.AbstractRegion - broker2 removing
consumer: ID:PC710618-49374-1554792737713-11:1:198:1 for destination:
topic://ACK
11065 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11065 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11065 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11065 [ActiveMQ Transport: tcp:///127.0.0.1:49378@50002] DEBUG
org.apache.activemq.broker.TransportConnector - Publishing:
tcp://PC710618:50002 for broker transport URI:
tcp://PC710618:50002?maximumConnections=1000&wireFormat.maxFrameSize=104857600
11065 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed interest for: ID:PC710618-49374-1554792737713-11:1:198:1
from DemandSub{broker1->broker2-49374-1554792737713-7:1:1:198,remotes:[]}
11065 [ActiveMQ Transport: tcp:///127.0.0.1:50002@49375] DEBUG
org.apache.activemq.network.ConduitBridge - broker1 on vm://broker1#0 from
broker2 removed
DemandSub{broker1->broker2-49374-1554792737713-7:1:1:198,remotes:[]}
===================
THIS ONE IS FINE
===================
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
