2015-11-18 11:07 GMT+01:00 magnusT <magnus.thylan...@greenhatpeople.com>: > 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.
Well , I've to make the silly question. Have your messages got TTL settings ? are clocks synchronized between all servers ? > > 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.
