RabbitMq cluster and Retain Message Replication

[Tushar]

version: 3.6.0

plugin: mqtt

We are using rabbitmq cluster and with two nodes. When pusblishing to a topic with retain flag it did not get replicated to other node.

Subscribing to any node shows the retain message that was published to that particular node.

Please suggest how we can get the retain mesasge to be replicated through out the cluster.

[Arman Petrosyan]

You need HA Queue

--
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.
To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/ed103e1b-5332-4f12-ab7f-dd78a052f047%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Tushar Sharma]

We have ha queues but its not working.

To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/CAF7xeozFfk3LpC7Lprh0KuoR0c7gOeSKoxY1C8-s_urM7AaNAQ%40mail.gmail.com.

[Arman Petrosyan]

Just use this Policy ---> 

"policies":[{"vhost":"/","name":"ha","pattern":"", "definition":{"ha-mode":"all","ha-sync-mode":"automatic","ha-sync-batch-size":5}}

вт, 25 июн. 2019 г. в 06:31, Tushar Sharma <tusharsh...@gmail.com>:

To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/CAA0_ngPxgqcGOzaSxhnBDWoQoEiWknw1GM3xoHHDd17XPZ2OBg%40mail.gmail.com.

[Tushar Sharma]

Hi Arman,

Thanks for you time.

But issue still persistes.

Each nodes only show the retain message that were directed to that particular node, it seems using above configiration retain messages are and replicated throughout the cluster.

To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/CAF7xeox0OQ3%3DZs3qEqQDP37mQgcsEL%2BnftW6SEuKJ3ZaOhJVKQ%40mail.gmail.com.

[Arman Petrosyan]

Ok, try to make durable queue

To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/CAA0_ngMwnv9q1VWRrL_cV9Jc%3DdkkmfTnjxvdpbpeejE-csj%3DDQ%40mail.gmail.com.

[Arman Petrosyan]

When do you create cluster then only queue metadata will save in node, but queue content be on master node( who crated queue

[Arman Petrosyan]

But when do you make queue durable on mirror node, then him content also save in miror node

[Tushar]

Hi,

My use case is bit different.

The queues are made by subscribers e.g:- mobile app, they can come and go any time.

Now assume their is no subscriber and hence no queue, a pusblisher publish a messages with retain flag. After few minutes a subscriber subscribers and hence a new queue (durable and auto delete is created).

Now retain message is not same if client connect on different nodes. 

[Tushar]

Hi,

Any pointers.

Can you guide me to setup retain message store as discussed in below link.

https://www.rabbitmq.com/mqtt.html#retained

Will this store be only for retained message.

[Michael Klishin]

As answered elsewhere, currently the only provided retained message store implementation is a per-node one (in RAM or on disk).

It should be reasonably easy to provide more implementations as the interface is a couple of operations (set and get a key). We plan on

making the store cluster-wide in a future release. There is no ETA.

--

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.

To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/253ea3bf-fa33-4b2e-b613-082b07d00fc5%40googlegroups.com.

For more options, visit https://groups.google.com/d/optout.

--

MK

Staff Software Engineer, Pivotal/RabbitMQ