RabbitMQ Queue Sync Between 2 Different Cluster

[Stephen Daniel]

Hi, I have two clusters of RabbitMQ with different network. 

I have a requirement to sync the data between these clusters including all the queue and message.

I can use the federation plugin to sync message between the cluster. But now I am confused about how to sync the queue between these clusters.

Is there any way to sync the queue between 2 cluster with different network?

For example, if I create queue A in cluster A than queue A will be automatically create in cluster B, but cluster A and cluster B are in different network.

Thanks.

[Michael Klishin]

That's an easy part: you can list queues using HTTP API [1][2] and declare

them on the other node. You can even export and import definitions but

that's not supposed to be used on the fly (only for bulk import, e.g. to spin up a stand by node).

The hard part is syncing message sets because queue federation doesn't replicate

and exchange federation is not bi-directional unless you set it up that way (in both clusters).

1. rabbitmq.com/management.html

2. https://raw.githack.com/rabbitmq/rabbitmq-management/rabbitmq_v3_6_2/priv/www/api/index.html

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To post to this group, send email to rabbitm...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

MK

Staff Software Engineer, Pivotal/RabbitMQ

[Stephen Daniel]

Hi thanks for the response.

How do I use the HTTP API to list and declare queue? Do I need to hit the API manually or it can be done automatically by some apps? 

Because in my requirement I need to sync the 2 clusters in real time.

Thanks,

[Michael Klishin]

It's an API. You can use it with curl or similar but ultimately it's supposed to be used by machines/programs ;)

[Stephen Daniel]

Hi, thanks for the answer, I will try your suggestion :) thanks so much.