Hi,
We have a two node network brokers set up. it can work fine two or
three days. Suddenly, every broker will try to create connection to each
other, but because
There are already has connected to each other, so it will throw a
“javax.jms.InvalidClientIDException”. The brokers will retry after 5
section, and the same exception will happened.
we started to see exceptions flooding in broker's log like the following:
2015-08-27 13:47:49,783 | INFO | Network connection between
vm://dynamic-broker1#214840 and tcp:///192.168.1.99:61617@59537 shutdown due
to a local error: javax.jms.InvalidClientIDException: Broker:
dynamic-broker1 - Client: NC_dynamic-broker2_inbound_dynamic-broker1 already
connected from vm://dynamic-broker1#184522 |
org.apache.activemq.network.DemandForwardingBridgeSupport |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59537, localBroker=
vm://dynamic-broker1#214840
2015-08-27 13:47:49,785 | INFO | dynamic-broker1 bridge to dynamic-broker2
stopped | org.apache.activemq.network.DemandForwardingBridgeSupport |
ActiveMQ BrokerService[dynamic-broker1] Task-6153
2015-08-27 13:47:55,285 | INFO | Establishing network connection from
vm://dynamic-broker1?async=false&network=true to tcp://192.168.1.99:61617 |
org.apache.activemq.network.DiscoveryNetworkConnector |
Notifier-MulticastDiscoveryAgent-listener:DiscoveryNetworkConnector:NC:BrokerService[dynamic-broker1]
2015-08-27 13:47:55,288 | WARN | Failed to add Connection
dynamic-broker1->dynamic-broker2-53741-1439958425038-214848:1 |
org.apache.activemq.broker.TransportConnection |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59539, localBroker=
vm://dynamic-broker1#214842
javax.jms.InvalidClientIDException: Broker: dynamic-broker1 - Client:
NC_dynamic-broker2_inbound_dynamic-broker1 already connected from
vm://dynamic-broker1#184522
at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:255)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.addConnection(ManagedRegionBroker.java:231)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:92)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:102)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:809)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:130)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:107)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:467)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.doStartLocalAndRemoteBridges(DemandForwardingBridgeSupport.java:420)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.access$500(DemandForwardingBridgeSupport.java:105)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:335)[activemq-broker-5.11.1.jar:5.11.1]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_51]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_51]
at java.lang.Thread.run(Thread.java:744)[:1.7.0_51]
2015-08-27 13:47:55,290 | INFO | Network connection between
vm://dynamic-broker1#214842 and tcp:///192.168.1.99:61617@59539 shutdown due
to a local error: javax.jms.InvalidClientIDException: Broker:
dynamic-broker1 - Client: NC_dynamic-broker2_inbound_dynamic-broker1 already
connected from vm://dynamic-broker1#184522 |
org.apache.activemq.network.DemandForwardingBridgeSupport |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59539, localBroker=
vm://dynamic-broker1#214842
2015-08-27 13:47:55,292 | INFO | dynamic-broker1 bridge to dynamic-broker2
stopped | org.apache.activemq.network.DemandForwardingBridgeSupport |
ActiveMQ BrokerService[dynamic-broker1] Task-6145
2015-08-27 13:48:00,916 | INFO | Establishing network connection from
vm://dynamic-broker1?async=false&network=true to tcp://192.168.1.99:61617 |
org.apache.activemq.network.DiscoveryNetworkConnector |
Notifier-MulticastDiscoveryAgent-listener:DiscoveryNetworkConnector:NC:BrokerService[dynamic-broker1]
2015-08-27 13:48:00,920 | WARN | Failed to add Connection
dynamic-broker1->dynamic-broker2-53741-1439958425038-214850:1 |
org.apache.activemq.broker.TransportConnection |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59542, localBroker=
vm://dynamic-broker1#214844
javax.jms.InvalidClientIDException: Broker: dynamic-broker1 - Client:
NC_dynamic-broker2_inbound_dynamic-broker1 already connected from
vm://dynamic-broker1#184522
at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:255)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.addConnection(ManagedRegionBroker.java:231)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:92)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:102)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:809)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:130)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:107)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:467)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.doStartLocalAndRemoteBridges(DemandForwardingBridgeSupport.java:420)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.access$500(DemandForwardingBridgeSupport.java:105)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:335)[activemq-broker-5.11.1.jar:5.11.1]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_51]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_51]
at java.lang.Thread.run(Thread.java:744)[:1.7.0_51]
2015-08-27 13:48:00,922 | INFO | Network connection between
vm://dynamic-broker1#214844 and tcp:///192.168.1.99:61617@59542 shutdown due
to a local error: javax.jms.InvalidClientIDException: Broker:
dynamic-broker1 - Client: NC_dynamic-broker2_inbound_dynamic-broker1 already
connected from vm://dynamic-broker1#184522 |
org.apache.activemq.network.DemandForwardingBridgeSupport |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59542, localBroker=
vm://dynamic-broker1#214844
2015-08-27 13:48:00,924 | INFO | dynamic-broker1 bridge to dynamic-broker2
stopped | org.apache.activemq.network.DemandForwardingBridgeSupport |
ActiveMQ BrokerService[dynamic-broker1] Task-6150
2015-08-27 13:48:05,923 | INFO | Establishing network connection from
vm://dynamic-broker1?async=false&network=true to tcp://192.168.1.99:61617 |
org.apache.activemq.network.DiscoveryNetworkConnector |
Notifier-MulticastDiscoveryAgent-listener:DiscoveryNetworkConnector:NC:BrokerService[dynamic-broker1]
2015-08-27 13:48:05,927 | WARN | Failed to add Connection
dynamic-broker1->dynamic-broker2-53741-1439958425038-214852:1 |
org.apache.activemq.broker.TransportConnection |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59544, localBroker=
vm://dynamic-broker1#214846
javax.jms.InvalidClientIDException: Broker: dynamic-broker1 - Client:
NC_dynamic-broker2_inbound_dynamic-broker1 already connected from
vm://dynamic-broker1#184522
at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:255)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.addConnection(ManagedRegionBroker.java:231)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:92)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:102)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:809)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:130)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:107)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:467)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.doStartLocalAndRemoteBridges(DemandForwardingBridgeSupport.java:420)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.access$500(DemandForwardingBridgeSupport.java:105)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:335)[activemq-broker-5.11.1.jar:5.11.1]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_51]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_51]
at java.lang.Thread.run(Thread.java:744)[:1.7.0_51]
2015-08-27 13:48:05,929 | INFO | Network connection between
vm://dynamic-broker1#214846 and tcp:///192.168.1.99:61617@59544 shutdown due
to a local error: javax.jms.InvalidClientIDException: Broker:
dynamic-broker1 - Client: NC_dynamic-broker2_inbound_dynamic-broker1 already
connected from vm://dynamic-broker1#184522 |
org.apache.activemq.network.DemandForwardingBridgeSupport |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59544, localBroker=
vm://dynamic-broker1#214846
2015-08-27 13:48:05,932 | INFO | dynamic-broker1 bridge to dynamic-broker2
stopped | org.apache.activemq.network.DemandForwardingBridgeSupport |
ActiveMQ BrokerService[dynamic-broker1] Task-6153
2015-08-27 13:48:10,930 | INFO | Establishing network connection from
vm://dynamic-broker1?async=false&network=true to tcp://192.168.1.99:61617 |
org.apache.activemq.network.DiscoveryNetworkConnector |
Notifier-MulticastDiscoveryAgent-listener:DiscoveryNetworkConnector:NC:BrokerService[dynamic-broker1]
2015-08-27 13:48:10,935 | WARN | Failed to add Connection
dynamic-broker1->dynamic-broker2-53741-1439958425038-214854:1 |
org.apache.activemq.broker.TransportConnection |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59545, localBroker=
vm://dynamic-broker1#214848
javax.jms.InvalidClientIDException: Broker: dynamic-broker1 - Client:
NC_dynamic-broker2_inbound_dynamic-broker1 already connected from
vm://dynamic-broker1#184522
at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:255)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.addConnection(ManagedRegionBroker.java:231)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:92)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:102)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:809)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:130)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:107)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:467)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.doStartLocalAndRemoteBridges(DemandForwardingBridgeSupport.java:420)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport.access$500(DemandForwardingBridgeSupport.java:105)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:335)[activemq-broker-5.11.1.jar:5.11.1]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_51]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_51]
at java.lang.Thread.run(Thread.java:744)[:1.7.0_51]
2015-08-27 13:48:10,937 | INFO | Network connection between
vm://dynamic-broker1#214848 and tcp:///192.168.1.99:61617@59545 shutdown due
to a local error: javax.jms.InvalidClientIDException: Broker:
dynamic-broker1 - Client: NC_dynamic-broker2_inbound_dynamic-broker1 already
connected from vm://dynamic-broker1#184522 |
org.apache.activemq.network.DemandForwardingBridgeSupport |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp:///192.168.1.99:61617@59545, localBroker=
vm://dynamic-broker1#214848
2015-08-27 13:48:10,938 | INFO | dynamic-broker1 bridge to dynamic-broker2
stopped | org.apache.activemq.network.DemandForwardingBridgeSupport |
ActiveMQ BrokerService[dynamic-broker1] Task-6150
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
<broker xmlns="http://activemq.apache.org/schema/core";
brokerName="dynamic-broker1" dataDirectory="${activemq.data}">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" producerFlowControl="true"
memoryLimit="20mb">
<deadLetterStrategy>
<individualDeadLetterStrategy queuePrefix="DLQ."
useQueueForQueueMessages="true" />
</deadLetterStrategy>
</policyEntry>
<policyEntry topic=">" producerFlowControl="true"
memoryLimit="20mb">
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<managementContext>
<managementContext createConnector="true"/>
</managementContext>
<networkConnectors>
<networkConnector uri="multicast://default"
dynamicOnly="true"
networkTTL="3"
prefetchSize="1"
decreaseNetworkConsumerPriority="true" />
</networkConnectors>
<persistenceAdapter>
<kahaDB directory="${activemq.data}/dynamic-broker1/kahadb"/>
</persistenceAdapter>
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="25 gb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="100 gb" name="foo"/>
</storeUsage>
<tempUsage>
<tempUsage limit="20 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<transportConnectors>
<transportConnector name="openwire1" uri="tcp://0.0.0.0:61616"/>
<transportConnector name="openwire2"
uri="tcp://192.168.1.99:61620"
discoveryUri="multicast://default" />
<transportConnector name="amqp"
uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="stomp"
uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="mqtt"
uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="ws"
uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
</broker>
<import resource="jetty.xml"/>
</beans>
--
View this message in context:
http://activemq.2283324.n4.nabble.com/throw-javax-jms-InvalidClientIDException-when-use-network-broker-tp4701756.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
