[rabbitmq-discuss] Messages not getting moved to the Upstream Federation, only empty queue is getting created.

Mon Aug 12 07:45:48 BST 2013

Hi,

I have two clusters Cluster1 & Cluster2.Cluster2 has a federation Upstream
to Cluster 1 and there is a HA-Federation-policy that whatever reources end
with pattern '.federate' will get this policy applied.
When i run my Java client and hit Cluster2, a Federation Exchange and a
Federation Queue bound it it gets created in Cluster1 but the queue is
empty.The newly created queue in Cluster2 does have message but the
fedration queue in Cluster1 doesnt have it.
Is my understanding of Federation is wrong?I believe thats how it should
happen that message should move from Cluster 2 to Cluster1 if i have a
upstream of Cluster 1 in cluster 2.

So the problem is the queue "queue.federate" in Cluster2 as shown below has
2 msgs but queue in Cluster1 "federation: exchange.federate ->
CLUSTER2 at zldv0435.vci.com" has 0 msgs. 

Here is the configuration of Cluster 2."exchange.federate" is the new
exchange created with queue "queue.federate":
 /opt/app/rabbitmq/sbin/rabbitmqctl list_parameters
Listing runtime parameters ...
federation      local-nodename  "CLUSTER2 at zldv0435.vci.com"
federation      local-username  "rbtadmin"
federation-upstream     HA-upstream-CLUSTER1-adminvhost
{"uri":"amqp://feduser:myFedPassword@zldv0433.vci.com:5691","max-hops":1}
...done.

 /opt/app/rabbitmq/sbin/rabbitmqctl list_policies
Listing policies ...
/       HA-Federation-adminvhost        \\.federate$   
{"federation-upstream-set":"all"}       0
/       HA-Mirror-Federate-adminvhost   \\.fedMirror$  
{"federation-upstream-set":"all","ha-mode":"all"}       2
/       HA-Mirror-adminvhost    \\.mirror$      {"ha-mode":"all"}       1
...done.

/opt/app/rabbitmq/sbin/rabbitmqctl list_exchanges
Listing exchanges ...
        direct
amq.direct      direct
amq.fanout      fanout
amq.headers     headers
amq.match       headers
amq.rabbitmq.log        topic
amq.rabbitmq.trace      topic
amq.topic       topic
exchange.federate       fanout
...done.

/opt/app/rabbitmq/sbin/rabbitmqctl list_queues
Listing queues ...
queue.federate  2
...done.

Here is the list of queues and exchanges in Cluster1:

/opt/app/rabbitmq/sbin/rabbitmqctl list_exchanges
Listing exchanges ...
        direct
amq.direct      direct
amq.fanout      fanout
amq.headers     headers
amq.match       headers
amq.rabbitmq.log        topic
amq.rabbitmq.trace      topic
amq.topic       topic
exchange.federate       fanout
federation: exchange.federate -> CLUSTER2 at zldv0435.vci.com A       
x-federation-upstream

 /opt/app/rabbitmq/sbin/rabbitmqctl list_queues
Listing queues ...
federation: exchange.federate -> CLUSTER2 at zldv0435.vci.com  0

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Messages-not-getting-moved-to-the-Upstream-Federation-only-empty-queue-is-getting-created-tp28726.html
Sent from the RabbitMQ mailing list archive at Nabble.com.