Attach a JMX viewer such as JConsole to each broker on the failing path, and look at whether you have the consumer you expect on the queue in question. What you find will determine what to look at next.
Tim On Nov 18, 2015 3:22 AM, "magnusT" <magnus.thylan...@greenhatpeople.com> wrote: > 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. >
