Hi,
We have three servers running activemq in a network of brokers
configuration. The general idea of our setup is to have messages sent on one
server replicated to the other two.
For this purpose we have setup composite queues (named *.composite) on each
server. These composite queues are forwarded to two separate queues
according to this config in activemq.xml:
<compositeQueue name="queue1.composite">
<forwardTo>
<queue physicalName="queue1.srv2" />
<queue physicalName="queue1.srv3" />
</forwardTo>
</compositeQueue>
(This config is on server1, on server2 the queue is forwarded to queue1.srv1
and queue1.srv3, and on server3 it would be forwarded to queue1.srv1 and
queue1.srv2)
On each server we have setup network connectors as follows:
SERVER1:
<networkConnector
uri="static:(tcp://server2ip:61616)?maxReconnectDelay=5000&useExponentialBackOff=false"
name="Srv1_to_Srv2" networkTTL="1">
<excludedDestinations>
<queue physicalName=">"/>
<topic physicalName=">"/>
</excludedDestinations>
<staticallyIncludedDestinations>
<queue physicalName="*.srv2"/>
</staticallyIncludedDestinations>
</networkConnector>
<networkConnector
uri="static:(tcp://server3ip:61616)?maxReconnectDelay=5000&useExponentialBackOff=false"
name="Srv1_to_Srv3" networkTTL="1">
<excludedDestinations>
<queue physicalName=">"/>
<topic physicalName=">"/>
</excludedDestinations>
<staticallyIncludedDestinations>
<queue physicalName="*.srv3"/>
</staticallyIncludedDestinations>
</networkConnector>
SERVER2:
<networkConnector
uri="static:(tcp://server1ip:61616)?maxReconnectDelay=5000&useExponentialBackOff=false"
name="Srv2_to_Srv1" networkTTL="1">
<excludedDestinations>
<queue physicalName=">"/>
<topic physicalName=">"/>
</excludedDestinations>
<staticallyIncludedDestinations>
<queue physicalName="*.srv1"/>
</staticallyIncludedDestinations>
</networkConnector>
<networkConnector
uri="static:(tcp://server3ip:61616)?maxReconnectDelay=5000&useExponentialBackOff=false"
name="Srv2_to_Srv3" networkTTL="1">
<excludedDestinations>
<queue physicalName=">"/>
<topic physicalName=">"/>
</excludedDestinations>
<staticallyIncludedDestinations>
<queue physicalName="*.srv3"/>
</staticallyIncludedDestinations>
</networkConnector>
SERVER3:
<networkConnector
uri="static:(tcp://server1ip:61616)?maxReconnectDelay=5000&useExponentialBackOff=false"
name="Srv3_to_Srv1" networkTTL="1">
<excludedDestinations>
<queue physicalName=">"/>
<topic physicalName=">"/>
</excludedDestinations>
<staticallyIncludedDestinations>
<queue physicalName="*.srv1"/>
</staticallyIncludedDestinations>
</networkConnector>
<networkConnector
uri="static:(tcp://server2ip:61616)?maxReconnectDelay=5000&useExponentialBackOff=false"
name="Srv3_to_Srv2" networkTTL="1">
<excludedDestinations>
<queue physicalName=">"/>
<topic physicalName=">"/>
</excludedDestinations>
<staticallyIncludedDestinations>
<queue physicalName="*.srv2"/>
</staticallyIncludedDestinations>
</networkConnector>
So, the idea as I said is that we publish a message on say
server1:queue1.composite and it is automatically sent to server2:queue1.srv2
and server3:queue1.srv3. That works fine, and it also works fine for server2
to send messages to server1 and server3.
But, when sending a message on server3 the message never reaches server1 or
server2. What´s funny is that when looking at enqueued & dequeued messages
in the web console of server3 the count is increased, but nothing arrives at
the other servers. No error messages are logged in the console either.
We are running amq v5.9 on server1, v5.7 on server2 and 5.11 on server 3.
Is there any reason why this should not work as configured as far as anyone
can tell? Is there a better way of doing it? Any help towards fixing this
issue will be greatly appreciated.
Best regards,
MagnusT
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Network-of-brokers-problems-tp4704041.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
