activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kube <ianl...@yahoo.com>
Subject InvalidClientIDException between network brokers
Date Tue, 13 May 2014 18:25:09 GMT
Hi, 
   We have a three node network brokers set up and was working fine. (named
respectably, mq01, mq02 and mq03)
Recently we decided to separate the connector for topic from the connector
for queue, 
and we started to see exceptions flooding in broker's log like the
following:
javax.jms.InvalidClientIDException: Broker: mq01 - Client:
queueOnly_mq02_inbound_mq01 already connected from vm://mq01#76162 

1. The complete activemq.xml is attached at very bottom.
2. We are using ActiveMQ 5.9.0
3. The full stack trace is :
2014-05-12 14:47:51,140 | WARN | Failed to add Connection
mq01->mq02-34867-1399699310371-38095:1 |
org.apache.activemq.broker.TransportConnection |
triggerStartAsyncNetworkBridgeCreation:
remoteBroker=tcp://mq02.xxx.xxxxxxxx/192.168.42.33:61688@39099, localBroker=
vm://mq01#76164 
javax.jms.InvalidClientIDException: Broker: mq01 - Client:
queueOnly_mq02_inbound_mq01 already connected from vm://mq01#76162 
at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:243) 
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:92) 
at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:90) 
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:92) 
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:92) 
at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:97)

at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:733)

at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139) 
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292) 
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:149) 
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116) 
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) 
at
org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138) 
at
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:127) 
at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:104) 
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) 
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)

at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86) 
at
org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:420)

at
org.apache.activemq.network.DemandForwardingBridgeSupport.doStartLocalAndRemoteBridges(DemandForwardingBridgeSupport.java:387)

at
org.apache.activemq.network.DemandForwardingBridgeSupport.access$500(DemandForwardingBridgeSupport.java:73)

at
org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:302)

at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) 
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) 
at java.lang.Thread.run(Thread.java:679)








***********************************************************************************************

<beans
  xmlns="http://www.springframework.org/schema/beans"
  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">
        <property name="locations">
            <value>file:${activemq.conf}/credentials.properties</value>
        </property>
    </bean>

    
    <bean id="logQuery"
class="org.fusesource.insight.log.log4j.Log4jLogQuery"
          lazy-init="false" scope="singleton"
          init-method="start" destroy-method="stop">
    </bean>

    
    <broker xmlns="http://activemq.apache.org/schema/core"
brokerName="${brokerName}" dataDirectory="${activemq.data}"
networkConnectorStartAsync="true">

        <destinationPolicy>
            <policyMap>
              <policyEntries>
                <policyEntry topic=">" >
                  <pendingMessageLimitStrategy>
                    <constantPendingMessageLimitStrategy limit="1000"/>
                  </pendingMessageLimitStrategy>
                </policyEntry>
                                <policyEntry queue=">" enableAudit="false"
queuePrefetch="10">
                                   <networkBridgeFilterFactory>
                                        
<conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true"/>
                                   </networkBridgeFilterFactory>
                                <deadLetterStrategy>
                                   <individualDeadLetterStrategy
queuePrefix="DLQ." useQueueForQueueMessages="true" />
                                </deadLetterStrategy>

                                </policyEntry>

              </policyEntries>
            </policyMap>
        </destinationPolicy>

        <managementContext>
            <managementContext createConnector="true"/>
        </managementContext>

        <persistenceAdapter>
            <kahaDB directory="${activemq.data}/kahadb"
concurrentStoreAndDispatchQueues="false"/>
        </persistenceAdapter>


          <systemUsage>
            <systemUsage sendFailIfNoSpaceAfterTimeout="30000">
                <memoryUsage>
                    <memoryUsage percentOfJvmHeap="70" />
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit="100 gb"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit="50 gb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>

        <networkConnectors>
                        <networkConnector name="topicOnly"
uri="multicast://default" networkTTL="3">
                                <dynamicallyIncludedDestinations>
                                        <topic physicalName=">"/>
                                </dynamicallyIncludedDestinations>
                        <excludedDestinations>
                                <topic physicalName="VirtualTopic.>"/>
                        </excludedDestinations>
                        </networkConnector>
                        <networkConnector name="queueOnly"
uri="multicast://default" conduitSubscriptions="false" networkTTL="3">
                                <dynamicallyIncludedDestinations>
                        <queue physicalName=">"/>
                        </dynamicallyIncludedDestinations>
                        </networkConnector>
                </networkConnectors>


        <transportConnectors>
            <transportConnector name="default" uri="nio://0.0.0.0:61688"
discoveryUri="multicast://default" updateClusterClients="true"
rebalanceClusterClients="true" updateClusterClientsOnRemove="true"/>
                        <transportConnector name="stomp+nio"
uri="stomp+nio://0.0.0.0:61613" discoveryUri="multicast://default"
updateClusterClients="true" rebalanceClusterClients="true"
updateClusterClientsOnRemove="true"/>
        </transportConnectors>

        <shutdownHooks>
            <bean xmlns="http://www.springframework.org/schema/beans"
class="org.apache.activemq.hooks.SpringContextHook" />
        </shutdownHooks>

    </broker>


    <import resource="jetty.xml"/>

</beans>



**************************

Any input/help is very much appreciated.

thanks





--
View this message in context: http://activemq.2283324.n4.nabble.com/InvalidClientIDException-between-network-brokers-tp4681090.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.

Mime
View raw message