You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by denisbrondy <de...@thalesaleniaspace.com> on 2019/04/08 11:32:41 UTC
Bridge fails and reconnect while remoting service through NOB
configuration
Hi guys,
I'm facing a very strange problem. I tested multiple versions of ACTIVEMQ
and I'm still seeing this issue on 5.15.9.
The setup is the following.
I have component which exposes a service interface with one basic method
which only perform a println. The exporter reads either a queue or a topic
to perform the service call and answers back to consumer to a topic / or
queue depending on the consumer strategy (we use JMSReply concept)
I have a component consuming the service method using a proxy that connects
the topic or queue for the acknowledgement of the service call and writes
the RPC on the queue or topic to the service. Service call is synchronous.
I'm using a network of broker with two brokers.
I'm voluntary connecting the service provider on Broker 1 and the service
consumer on Broker 2 to test the message forwarding in between the two. I'm
performing 2000 service calls.
Setup 1: If I ONLY configure a full duplex bridge from B1 to B2, the test
passes.
Setup 2: If I configure two full duplex bridges from B1 to B2 and from B2 to
B1 (which I don't known if it's recommended), the test passes but I'm
observing network bridges disconnecting and reconnecting during the stress
test.
Setup 3: If I only configure two half duplex bridge from B1 to B2 and from
B2 to B1, the test fails after some calls. I see also my network bridge
disconnecting and reconnecting during the stress test
Do you have an idea of what is going wrong ?
Tks for your help !
denis
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: Bridge fails and reconnect while remoting service through NOB
configuration
Posted by denisbrondy <de...@thalesaleniaspace.com>.
I all.
I'm trying to continue my troobleshooting..
I downgrade to activemq 5.5.1 because we used this version production and it
seems the problem is still observable.
With the old logger, I have a trace now: with a
concurrentModificationException.
Please, any help ?
mai 14, 2019 3:32:26 PM
org.apache.activemq.network.DemandForwardingBridgeSupport
serviceRemoteException
AVERTISSEMENT: Network connection between vm://broker1#0 and
tcp:///127.0.0.1:50002 shutdown due to a remote error:
java.util.ConcurrentModificationException
mai 14, 2019 3:32:26 PM org.apache.activemq.broker.TransportConnector stop
INFOS: Connector vm://broker1 Stopped
mai 14, 2019 3:32:26 PM
org.apache.activemq.network.DemandForwardingBridgeSupport stop
INFOS: broker1 bridge to broker2 stopped
mai 14, 2019 3:32:26 PM
org.apache.activemq.network.DiscoveryNetworkConnector onServiceAdd
INFOS: Establishing network connection from
vm://broker1?async=false&network=true to
tcp://127.0.0.1:50002?connectionTimeout=2000&soTimeout=2000
mai 14, 2019 3:32:26 PM org.apache.activemq.broker.TransportConnector start
INFOS: Connector vm://broker1 Started
mai 14, 2019 3:32:26 PM
org.apache.activemq.network.DemandForwardingBridgeSupport startLocalBridge
INFOS: Network connection between vm://broker1#4 and
tcp:///127.0.0.1:50002(broker2) has been established.
com.thalesaleniaspace.openscc.exporter.spring.jms.MockServiceException: A
runtime exception occurred during the method invocation.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.invoke(JmsInvokerProxyFactoryBean.java:104)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
at
org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
at com.sun.proxy.$Proxy9.call(Unknown Source)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.integration.Caller.run(Caller.java:40)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.integration.ActiveMQ3NodesTest.testOnQueue(ActiveMQ3NodesTest.java:58)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at
org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
at
org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
Caused by: org.springframework.remoting.RemoteTimeoutException: Receive
timeout when calling service 'IMockService' method 'call' after 2000 ms
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.onReceiveTimeout(JmsInvokerProxyFactoryBean.java:140)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.executeRequest(JmsInvokerProxyFactoryBean.java:128)
at
org.springframework.jms.remoting.JmsInvokerClientInterceptor.invoke(JmsInvokerClientInterceptor.java:198)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.invoke(JmsInvokerProxyFactoryBean.java:90)
... 29 more
com.thalesaleniaspace.openscc.exporter.spring.jms.MockServiceException: A
runtime exception occurred during the method invocation.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.invoke(JmsInvokerProxyFactoryBean.java:104)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
at
org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
at com.sun.proxy.$Proxy9.call(Unknown Source)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.integration.Caller.run(Caller.java:40)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.integration.ActiveMQ3NodesTest.testOnQueue(ActiveMQ3NodesTest.java:58)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at
org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
at
org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
Caused by: org.springframework.remoting.RemoteTimeoutException: Receive
timeout when calling service 'IMockService' method 'call' after 2000 ms
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.onReceiveTimeout(JmsInvokerProxyFactoryBean.java:140)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.executeRequest(JmsInvokerProxyFactoryBean.java:128)
at
org.springframework.jms.remoting.JmsInvokerClientInterceptor.invoke(JmsInvokerClientInterceptor.java:198)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.invoke(JmsInvokerProxyFactoryBean.java:90)
... 29 more
mai 14, 2019 3:32:31 PM
org.apache.activemq.network.DemandForwardingBridgeSupport
serviceRemoteException
AVERTISSEMENT: Network connection between vm://broker1#4 and
tcp:///127.0.0.1:50002 shutdown due to a remote error:
java.util.ConcurrentModificationException
com.thalesaleniaspace.openscc.exporter.spring.jms.MockServiceException: A
runtime exception occurred during the method invocation.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.invoke(JmsInvokerProxyFactoryBean.java:104)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
at
org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
at com.sun.proxy.$Proxy9.call(Unknown Source)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.integration.Caller.run(Caller.java:40)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.integration.ActiveMQ3NodesTest.testOnQueue(ActiveMQ3NodesTest.java:58)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at
org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
at
org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
*Caused by: java.util.ConcurrentModificationException
at java.util.HashMap$HashIterator.nextNode(HashMap.java:1437)
at java.util.HashMap$EntryIterator.next(HashMap.java:1471)
at java.util.HashMap$EntryIterator.next(HashMap.java:1469)
at java.util.HashMap.putMapEntries(HashMap.java:511)
at java.util.HashMap.<init>(HashMap.java:489)
at
org.slf4j.helpers.BasicMDCAdapter.getCopyOfContextMap(BasicMDCAdapter.java:130)
at org.slf4j.MDC.getCopyOfContextMap(MDC.java:176)
at
org.apache.activemq.util.MDCHelper.getCopyOfContextMap(MDCHelper.java:30)
at
org.apache.activemq.thread.PooledTaskRunner.<init>(PooledTaskRunner.java:42)
at
org.apache.activemq.thread.TaskRunnerFactory.createTaskRunner(TaskRunnerFactory.java:80)
at
org.apache.activemq.ActiveMQSessionExecutor.wakeup(ActiveMQSessionExecutor.java:101)
at
org.apache.activemq.ActiveMQMessageConsumer.start(ActiveMQMessageConsumer.java:1339)
at
org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:261)
at
org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1116)
at
org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1060)
at
org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:973)
at
*com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.doExecuteRequest(JmsInvokerProxyFactoryBean.java:167)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.executeRequest(JmsInvokerProxyFactoryBean.java:124)
at
org.springframework.jms.remoting.JmsInvokerClientInterceptor.invoke(JmsInvokerClientInterceptor.java:198)
at
com.thalesaleniaspace.openscc.exporter.spring.jms.redundancy.JmsInvokerProxyFactoryBean.invoke(JmsInvokerProxyFactoryBean.java:90)
... 29 more
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: Bridge fails and reconnect while remoting service through NOB
configuration
Posted by denisbrondy <de...@thalesaleniaspace.com>.
Hi guys....
A small up ! :-)
Any idea ?
TKs
denis
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: Bridge fails and reconnect while remoting service through NOB
configuration
Posted by denisbrondy <de...@thalesaleniaspace.com>.
Hi guys,
Here is the source code and associated unit tests.
https://github.com/denisbrondy/testactivemqnob
denis
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: Bridge fails and reconnect while remoting service through NOB
configuration
Posted by denisbrondy <de...@thalesaleniaspace.com>.
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
Re: Bridge fails and reconnect while remoting service through NOB
configuration
Posted by denisbrondy <de...@thalesaleniaspace.com>.
Hi Tim,
Tks for your reply.
Ok for Config 2 not recommended but I agree config 1 and 3 should behave the
same.
I'm not using durable subscriptions, no persistency at all, only classic bus
capabilities.
I'm performing the same tests for all configuration and have clearly some
different results. I can provide you a maven project with the unitary tests
I run and you should be able to see the results from your side. How can I
forward it to you ?
denis
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: Bridge fails and reconnect while remoting service through NOB configuration
Posted by Tim Bain <tb...@alumni.duke.edu>.
Config 2 isn't recommended, but configs 1 and 3 are both valid and should
behave equivalently. The fact that they don't is concerning.
Is your 2000-message test the same thing as your stress test, or are those
different tests? If they're different, can you please give more details
about how the 2000-message test fails?
Can you give more details about the network bridge disconnections? Logs,
frequency, etc.? Do you have any slow consumer handling in place? And are
you using durable or non-durable topic subscriptions?
Tim
On Mon, Apr 8, 2019, 5:32 AM denisbrondy <de...@thalesaleniaspace.com>
wrote:
> Hi guys,
>
> I'm facing a very strange problem. I tested multiple versions of ACTIVEMQ
> and I'm still seeing this issue on 5.15.9.
>
> The setup is the following.
>
> I have component which exposes a service interface with one basic method
> which only perform a println. The exporter reads either a queue or a topic
> to perform the service call and answers back to consumer to a topic / or
> queue depending on the consumer strategy (we use JMSReply concept)
>
> I have a component consuming the service method using a proxy that connects
> the topic or queue for the acknowledgement of the service call and writes
> the RPC on the queue or topic to the service. Service call is synchronous.
>
> I'm using a network of broker with two brokers.
>
> I'm voluntary connecting the service provider on Broker 1 and the service
> consumer on Broker 2 to test the message forwarding in between the two. I'm
> performing 2000 service calls.
>
> Setup 1: If I ONLY configure a full duplex bridge from B1 to B2, the test
> passes.
>
> Setup 2: If I configure two full duplex bridges from B1 to B2 and from B2
> to
> B1 (which I don't known if it's recommended), the test passes but I'm
> observing network bridges disconnecting and reconnecting during the stress
> test.
>
> Setup 3: If I only configure two half duplex bridge from B1 to B2 and from
> B2 to B1, the test fails after some calls. I see also my network bridge
> disconnecting and reconnecting during the stress test
>
> Do you have an idea of what is going wrong ?
>
> Tks for your help !
> denis
>
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>