activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Brian Diesenhaus (JIRA)" <j...@activemq.org>
Subject [jira] Commented: (AMQ-639) Broker is not re-connecting to a network of brokers after going down and then being brought back up
Date Fri, 17 Mar 2006 19:13:26 GMT
    [ http://jira.activemq.org/jira//browse/AMQ-639?page=comments#action_35812 ] 

Brian Diesenhaus commented on AMQ-639:
--------------------------------------

I did some testing this morning and here is what I found: 
1. The broker is re-connecting. Looking at the connection in the JMX console all the brokers
can see each other. This was not the case before. 
2. The brokers that were not brought down are throwing the below exception when the broker
re-connects. 
3. Running the test again after the broker comes up only about 1/3 of the message make it
to the broker that was brought back up and then it .


INFO: Async error occurred: javax.jms.InvalidClientIDException: Broker: bfe-grieg - Client:
NC_bfe-holst_inboundbfe-grieg already connected
javax.jms.InvalidClientIDException: Broker: bfe-grieg - Client: NC_bfe-holst_inboundbfe-grieg
already connected
        at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:151)
        at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:64)
        at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:67)
        at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:64)
        at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:76)
        at org.apache.activemq.broker.AbstractConnection.processAddConnection(AbstractConnection.java:500)
        at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:106)
        at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:196)
        at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
        at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:88)
        at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:70)
        at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:75)
        at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
        at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:55)
        at org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:175)
        at org.apache.activemq.network.DemandForwardingBridgeSupport$3.run(DemandForwardingBridgeSupport.java:147)


> Broker is not re-connecting to a network of brokers after going down and then being brought
back up
> ---------------------------------------------------------------------------------------------------
>
>          Key: AMQ-639
>          URL: http://jira.activemq.org/jira//browse/AMQ-639
>      Project: ActiveMQ
>         Type: Bug

>   Components: Broker
>     Versions: 4.0 M4
>     Reporter: Brian Diesenhaus
>     Priority: Critical
>      Fix For: 4.0 M5

>
>
> I have set up a network of brokers with the following configuration:
> <beans xmlns="http://activemq.org/config/1.0">
>   <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
>   
>   <broker brokerName="bfe-${HOSTNAME}" useJmx="true" persistent="false" managementContext="#mc">

>     <destinationPolicy>
>       <policyMap>
>         <policyEntries>
>           <policyEntry queue=">" memoryLimit="5000000"/>
>         </policyEntries>
>       </policyMap>
>    </destinationPolicy>
>    <memoryManager>
>      <usageManager limit="100000000"/>
>     </memoryManager> 
>  
>     <transportConnectors>
>     	<transportConnector uri="tcp://localhost:61616" discoveryUri="multicast://bfe2"/>

>     </transportConnectors>
>     
>     <networkConnectors>
>       <!-- by default just auto discover the other brokers -->
>       <networkConnector uri="multicast://bfe2"/>
>     </networkConnectors>
>    </broker>
>   
>  <bean id="mc" class="org.apache.activemq.broker.jmx.ManagementContext">
>     <property name="connectorPort" value="1099"/>
>     <property name="connectorPath" value="/jmxrmibfe-1"/>
>   </bean>
>  
> </beans>
> I then run a series of tests (producing and consuming on the network of brokers). Then
I shut one broker down and then start it up again  it can't see the other brokers in the network
but the other brokers can see it. 

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
   http://jira.activemq.org/jira//secure/Administrators.jspa
-
For more information on JIRA, see:
   http://www.atlassian.com/software/jira


Mime
View raw message