[ https://issues.apache.org/activemq/browse/AMQ-1301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_39767 ]
Pieter commented on AMQ-1301: ----------------------------- Unfortunately I get the same behaviour again. I can't find a reliable way to restore a network of brokers after one broker is brought down, other than shutting down all brokers and removing the data directories. This specific behaviour is perhaps a bug in the loop detection? I could image it gets a message from the broker, sees it as a new messages, and forwards it again to the other broker, ad infinitum. In any case, not being able to restore a network of brokers without problems makes the network practically useless. > Problems with reconnecting broker to network of brokers after broker shutdown > ----------------------------------------------------------------------------- > > Key: AMQ-1301 > URL: https://issues.apache.org/activemq/browse/AMQ-1301 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 4.1.2 > Reporter: Pieter > > When using a network of brokers, I get problems in the following scenario. > Consider two brokers, broker1 and broker2, connected to eachother (see config > below). Everything works ok: durable consumers on topics get messages sent to > either server. The messages are all persistent. > The problems occur in this scenario: > 1. Bring down one of the brokers, let's say broker2 (all consumers and > producers connect to the other server, without any problems) > 2. Start the killed broker2 again > 3. The broker2 reconnects to the network as expected > 4. However, messages don't get propagated correctly on the network anymore. > Consumers on broker1 don't get messages sent to broker2 anymore, and messages > from broker2 get sent to broker1 over and over again. This can also be seen > in the webconsole for example, where the number of messages in the queue > grows rapidly. > The only way to fix this is to kill all brokers, and remove the persistent > message stores. THis is unacceptable, since this loses messages. > Config is below: > <beans xmlns="http://www.springframework.org/schema/beans" > xmlns:util="http://www.springframework.org/schema/util"> > > <broker brokerName="broker1" useJmx="true" persistent="true" > xmlns="http://activemq.org/config/1.0"> > > <persistenceAdapter> > <journaledJDBC journalLogFiles="5" > dataDirectory="${activemq.base}/activemq-data"/> > </persistenceAdapter> > > <transportConnectors> > <transportConnector name="openwire" uri="tcp://localhost:61616"/> > <transportConnector name="stomp" uri="stomp://localhost:61627"/> > </transportConnectors> > > <networkConnectors> > <networkConnector name="ha-network" > uri="static://(tcp://localhost:61618)" networkTTL="5"/> > </networkConnectors> > </broker> > <beans xmlns="http://www.springframework.org/schema/beans" > xmlns:util="http://www.springframework.org/schema/util"> > > <broker brokerName="broker2" useJmx="true" persistent="true" > xmlns="http://activemq.org/config/1.0"> > > <persistenceAdapter> > <journaledJDBC journalLogFiles="5" > dataDirectory="${activemq.base}/activemq-data"/> > </persistenceAdapter> > > <transportConnectors> > <transportConnector name="openwire" uri="tcp://localhost:61618"/> > <transportConnector name="stomp" uri="stomp://localhost:61628"/> > </transportConnectors> > > <networkConnectors> > <networkConnector name="ha-network" > uri="static://(tcp://localhost:61616)" networkTTL="5"/> > </networkConnectors> > </broker> -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.