# Indexing RabbitMQ queues

**URL:** <https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725>\
**Category:** Elasticsearch\
**Created:** [October 31, 2011, 10:46am UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725 "2011-10-31T10:46:05Z")\
**Posts on this page:** 8\
**Page:** 1

<div class="post-metadata">

**Author:** ![lyes\_zaiko](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/lyes_zaiko/32/11250_2.png) [@lyes\_zaiko](https://discuss.elastic.co/u/lyes_zaiko)\
**Post date:** [October 31, 2011, 10:46am UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725/1 "2011-10-31T10:46:05Z")

</div>

Hello all!

Is there any documentation about how to index data contained in a  
RabbitMQ Queue?

thanks

---

<div class="post-metadata">

**Author:** ![Damien\_Hardy](https://avatars.discourse-cdn.com/v4/letter/d/779978/32.png) [@Damien\_Hardy](https://discuss.elastic.co/u/Damien_Hardy)\
**Post date:** [October 31, 2011, 11:10am UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725/2 "2011-10-31T11:10:39Z")

</div>

2011/10/31 lyes zaiko [lyesjob@gmail.com](mailto:lyesjob@gmail.com)

> Hello all!
> 
> Is there any documentation about how to index data contained in a  
> RabbitMQ Queue?
> 
> thanks

Hello,

Yes there is :

> **[Elasticsearch Platform — Find real-time answers at scale](https://www.elastic.co)**
>
> Power insights and outcomes with the Elasticsearch Platform and AI. See into your data and find answers that matter with enterprise solutions designed to help you build, observe, and protect. Try Elasticsearch free today.

But ES cannot yet subscribe to active-active HA queue (instroduced in  
RabbitMQ 2.6)

Best regards,

--  
Damien

---

<div class="post-metadata">

**Author:** ![lyes\_zaiko](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/lyes_zaiko/32/11250_2.png) [@lyes\_zaiko](https://discuss.elastic.co/u/lyes_zaiko)\
**Post date:** [October 31, 2011, 11:18am UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725/3 "2011-10-31T11:18:08Z")

</div>

Thank you for the quick reply  
I'll check with it

On Oct 31, 12:10 pm, Damien Hardy [damienhardy....@gmail.com](mailto:damienhardy....@gmail.com) wrote:

> 2011/10/31 lyes zaiko [lyes...@gmail.com](mailto:lyes...@gmail.com)
> 
> > Hello all!
> 
> > Is there any documentation about how to index data contained in a  
> > RabbitMQ Queue?
> 
> > thanks
> 
> Hello,
> 
> Yes there is :[Elasticsearch Platform — Find real-time answers at scale | Elastic](http://www.elasticsearch.org/guide/reference/river/rabbitmq.html)  
> But ES cannot yet subscribe to active-active HA queue (instroduced in  
> RabbitMQ 2.6)
> 
> Best regards,
> 
> --  
> Damien

---

<div class="post-metadata">

**Author:** ![kimchy](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/kimchy/32/44952_2.png) [@kimchy](https://discuss.elastic.co/u/kimchy)\
**Post date:** [October 31, 2011, 5:35pm UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725/4 "2011-10-31T17:35:16Z")

</div>

Heya Demian, what needs to be done in ES to support active active  
registration?

On Mon, Oct 31, 2011 at 1:10 PM, Damien Hardy [damienhardy.bal@gmail.com](mailto:damienhardy.bal@gmail.com)wrote:

> 2011/10/31 lyes zaiko [lyesjob@gmail.com](mailto:lyesjob@gmail.com)
> 
> > Hello all!
> > 
> > Is there any documentation about how to index data contained in a  
> > RabbitMQ Queue?
> > 
> > thanks
> 
> Hello,
> 
> Yes there is :  
> [Elasticsearch Platform — Find real-time answers at scale | Elastic](http://www.elasticsearch.org/guide/reference/river/rabbitmq.html)  
> But ES cannot yet subscribe to active-active HA queue (instroduced in  
> RabbitMQ 2.6)
> 
> Best regards,
> 
> --  
> Damien

---

<div class="post-metadata">

**Author:** ![Damien\_Hardy](https://avatars.discourse-cdn.com/v4/letter/d/779978/32.png) [@Damien\_Hardy](https://discuss.elastic.co/u/Damien_Hardy)\
**Post date:** [October 31, 2011, 6:24pm UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725/5 "2011-10-31T18:24:11Z")

</div>

Hi Shay,

We have done some tests pre-creating the queue withe mirror  
fonctionnality on a 2 ndes RMQ clusters via the web interface and  
tried to configure ES as consumer and it fails.

According to [Classic Queue Mirroring — RabbitMQ](http://www.rabbitmq.com/ha.html) We suppose an HashMap {"x-  
ha-policy": "all"} should be added instead of null at  
[https://github.com/elasticsearch/elasticsearch/blob/master/plugins/river/rabbitmq/src/main/java/org/elasticsearch/river/rabbitmq/RabbitmqRiver.java#L183](https://github.com/elasticsearch/elasticsearch/blob/master/plugins/river/rabbitmq/src/main/java/org/elasticsearch/river/rabbitmq/RabbitmqRiver.java#L183)

ES river config should be also complexified by adding a lists of RMQ  
nodes of replication.

It could be also an opportunity to upgrade the client version.

We planned to do some gitpull on this subjet when some others stuff  
are over (some dead lines are coming 🙂

Thank you,

--  
Damien

On 31 oct, 18:35, Shay Banon [kim...@gmail.com](mailto:kim...@gmail.com) wrote:

> Heya Demian, what needs to be done in ES to support active active  
> registration?
> 
> On Mon, Oct 31, 2011 at 1:10 PM, Damien Hardy [damienhardy....@gmail.com](mailto:damienhardy....@gmail.com)wrote:
> 
> > 2011/10/31 lyes zaiko [lyes...@gmail.com](mailto:lyes...@gmail.com)
> 
> > > Hello all!
> 
> > > Is there any documentation about how to index data contained in a  
> > > RabbitMQ Queue?
> 
> > > thanks
> 
> > Hello,
> 
> > Yes there is :  
> > [Elasticsearch Platform — Find real-time answers at scale | Elastic](http://www.elasticsearch.org/guide/reference/river/rabbitmq.html)  
> > But ES cannot yet subscribe to active-active HA queue (instroduced in  
> > RabbitMQ 2.6)
> 
> > Best regards,
> 
> > --  
> > Damien

---

<div class="post-metadata">

**Author:** ![Rohit\_Raghuvanshi](https://avatars.discourse-cdn.com/v4/letter/r/bcef8e/32.png) [@Rohit\_Raghuvanshi](https://discuss.elastic.co/u/Rohit_Raghuvanshi)\
**Post date:** [November 22, 2016, 3:16pm UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725/6 "2016-11-22T15:16:21Z")

</div>

Link is not active

---

<div class="post-metadata">

**Author:** ![mainec](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/mainec/32/5557_2.png) [@mainec](https://discuss.elastic.co/u/mainec)\
**Post date:** [November 23, 2016, 10:27am UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725/7 "2016-11-23T10:27:45Z")

</div>

Assuming you are currently looking for a solution to the same problem: And the suggested solution isn't valid anymore as Rivers have long since been deprecated/ removed.

Instead you might want to checkout Logstash:

[https://www.elastic.co/guide/en/logstash/current/plugins-inputs-rabbitmq.html](https://www.elastic.co/guide/en/logstash/current/plugins-inputs-rabbitmq.html)

Hope this helps,  
Isabel

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [July 5, 2017, 10:05pm UTC](https://discuss.elastic.co/t/indexing-rabbitmq-queues/5725/8 "2017-07-05T22:05:30Z")

</div>


