# Patch for RabbitMQ river **URL:** \ **Category:** Elasticsearch\ **Created:** [December 6, 2011, 3:52pm UTC](https://discuss.elastic.co/t/patch-for-rabbitmq-river/6079 "2011-12-06T15:52:18Z")\ **Posts on this page:** 7\ **Page:** 1
**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:** [December 6, 2011, 3:52pm UTC](https://discuss.elastic.co/t/patch-for-rabbitmq-river/6079/1 "2011-12-06T15:52:18Z")
Hello, I join a patch to my mail to make HA Queue on RabbitMQ available for Elasticsearch. [http://www.elasticsearch.org/guide/reference/river/rabbitmq.html](http://www.elasticsearch.org/guide/reference/river/rabbitmq.html) Based on the new repo [https://github.com/elasticsearch/elasticsearch-river-rabbitmq](https://github.com/elasticsearch/elasticsearch-river-rabbitmq) (congrats for the good job Shay ๐Ÿ™‚ Reading this : [http://www.rabbitmq.com/ha.html](http://www.rabbitmq.com/ha.html) \* - ``` */!\* big warn only "x-ha-policy" : "all" is fonctionnal */!\* ``` see [http://old.nabble.com/HA-queue-seems-never-to-get-fully-created-td32529015.html#a32582000](http://old.nabble.com/HA-queue-seems-never-to-get-fully-created-td32529015.html#a32582000) Config for HA Queue should be : curl -XPUT 'localhost:9200/\_river/my\_river/\_meta' -d '{ "type" : "rabbitmq", "rabbitmq" : { "host" : "localhost", "port" : 5672, "user" : "guest", "pass" : "guest", "vhost" : "/", "queue" : "elasticsearch", "exchange" : "elasticsearch", "routing\_key" : "elasticsearch", "exchange\_type" : "direct", "exchange\_durable" : true, "queue\_durable" : true, "queue\_auto\_delete" : false, "args" : { "x-ha-policy" : "all" } }, "index" : { "bulk\_size" : 100, "bulk\_timeout" : "10ms", "ordered" : false } } And should support future "x-ha-policy" : "nodes" (when bug will be closed on RabbitMQ) with : curl -XPUT 'localhost:9200/\_river/my\_river/\_meta' -d '{ "type" : "rabbitmq", "rabbitmq" : { "host" : "localhost", "port" : 5672, "user" : "guest", "pass" : "guest", "vhost" : "/", "queue" : "elasticsearch", "exchange" : "elasticsearch", "routing\_key" : "elasticsearch", "exchange\_type" : "direct", "exchange\_durable" : true, "queue\_durable" : true, "queue\_auto\_delete" : false, "args" : { "x-ha-policy" : "nodes", "x-ha-policy-params" : [ "rabbit1@localhost", "rabbit2@localhost" ] } }, "index" : { "bulk\_size" : 100, "bulk\_timeout" : "10ms", "ordered" : false } } Cheers, -- Damien ---
**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:** [December 6, 2011, 7:45pm UTC](https://discuss.elastic.co/t/patch-for-rabbitmq-river/6079/2 "2011-12-06T19:45:15Z")
Heya, thanks for the work!. Can you send a pull request with the change? On Tue, Dec 6, 2011 at 5:52 PM, Damien Hardy [damienhardy.bal@gmail.com](mailto:damienhardy.bal@gmail.com)wrote: > Hello, > > I join a patch to my mail to make HA Queue on RabbitMQ available for > Elasticsearch. > [Elasticsearch Platform โ€” Find real-time answers at scale | Elastic](http://www.elasticsearch.org/guide/reference/river/rabbitmq.html) > > Based on the new repo > [GitHub - elastic/elasticsearch-river-rabbitmq: RabbitMQ River Plugin for elasticsearch (STOPPED)](https://github.com/elasticsearch/elasticsearch-river-rabbitmq) (congrats > for the good job Shay ๐Ÿ™‚ > > Reading this : [Classic Queue Mirroring โ€” RabbitMQ](http://www.rabbitmq.com/ha.html) \* > > - > > ``` > */!\* big warn only "x-ha-policy" : "all" is fonctionnal */!\* > > ``` > > see > [http://old.nabble.com/HA-queue-seems-never-to-get-fully-created-td32529015.html#a32582000](http://old.nabble.com/HA-queue-seems-never-to-get-fully-created-td32529015.html#a32582000) > > Config for HA Queue should be : > curl -XPUT 'localhost:9200/\_river/my\_river/\_meta' -d '{ > "type" : "rabbitmq", > "rabbitmq" : { > "host" : "localhost", > "port" : 5672, > "user" : "guest", > "pass" : "guest", > "vhost" : "/", > "queue" : "elasticsearch", > "exchange" : "elasticsearch", > "routing\_key" : "elasticsearch", > "exchange\_type" : "direct", > "exchange\_durable" : true, > "queue\_durable" : true, > "queue\_auto\_delete" : false, > "args" : { "x-ha-policy" : "all" } > }, > "index" : { > "bulk\_size" : 100, > "bulk\_timeout" : "10ms", > "ordered" : false > } > } > > And should support future "x-ha-policy" : "nodes" (when bug will be closed > on RabbitMQ) with : > curl -XPUT 'localhost:9200/\_river/my\_river/\_meta' -d '{ > "type" : "rabbitmq", > "rabbitmq" : { > "host" : "localhost", > "port" : 5672, > "user" : "guest", > "pass" : "guest", > "vhost" : "/", > "queue" : "elasticsearch", > "exchange" : "elasticsearch", > "routing\_key" : "elasticsearch", > "exchange\_type" : "direct", > "exchange\_durable" : true, > "queue\_durable" : true, > "queue\_auto\_delete" : false, > "args" : { > "x-ha-policy" : "nodes", > "x-ha-policy-params" : [ "rabbit1@localhost", > "rabbit2@localhost" ] > } > }, > "index" : { > "bulk\_size" : 100, > "bulk\_timeout" : "10ms", > "ordered" : false > } > } > > Cheers, > > -- > Damien ---
**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:** [December 7, 2011, 10:42am UTC](https://discuss.elastic.co/t/patch-for-rabbitmq-river/6079/3 "2011-12-07T10:42:01Z")
Hello, pull request applied : > Good news ๐Ÿ™‚ RabbitMQ 2.7.0 is out [http://old.nabble.com/RabbitMQ-2.7.0-is-released-ts32810200.html](http://old.nabble.com/RabbitMQ-2.7.0-is-released-ts32810200.html) And bugfix so : - could not declare a mirrored queue with a policy of "nodes" and an explicit list of node names Cheers, -- Damien ---
**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:** [December 7, 2011, 3:49pm UTC](https://discuss.elastic.co/t/patch-for-rabbitmq-river/6079/4 "2011-12-07T15:49:18Z")
cool, upgraded to 2.7.0 as well as pulling your change. On Wed, Dec 7, 2011 at 12:42 PM, Damien Hardy [damienhardy.bal@gmail.com](mailto:damienhardy.bal@gmail.com)wrote: > Hello, > > pull request applied : > [- add extra args to support ha queue by dhardy92 ยท Pull Request #1 ยท elastic/elasticsearch-river-rabbitmq ยท GitHub](https://github.com/elasticsearch/elasticsearch-river-rabbitmq/pull/1) > > Good news ๐Ÿ™‚ RabbitMQ 2.7.0 is out > [http://old.nabble.com/RabbitMQ-2.7.0-is-released-ts32810200.html](http://old.nabble.com/RabbitMQ-2.7.0-is-released-ts32810200.html) > And bugfix so : > > - could not declare a mirrored queue with a policy of "nodes" and an > explicit > list of node names > > Cheers, > > -- > Damien ---
**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:** [December 7, 2011, 3:49pm UTC](https://discuss.elastic.co/t/patch-for-rabbitmq-river/6079/5 "2011-12-07T15:49:41Z")
btw, tell me if you want 1.1.0 release, its simple now that its outside of elasticsearch :). On Wed, Dec 7, 2011 at 5:49 PM, Shay Banon [kimchy@gmail.com](mailto:kimchy@gmail.com) wrote: > cool, upgraded to 2.7.0 as well as pulling your change. > > On Wed, Dec 7, 2011 at 12:42 PM, Damien Hardy [damienhardy.bal@gmail.com](mailto:damienhardy.bal@gmail.com)wrote: > > > Hello, > > > > pull request applied : > > [https://github.com/elasticsearch/elasticsearch-river-rabbitmq/pull/1](https://github.com/elasticsearch/elasticsearch-river-rabbitmq/pull/1) > > > > Good news ๐Ÿ™‚ RabbitMQ 2.7.0 is out > > [http://old.nabble.com/RabbitMQ-2.7.0-is-released-ts32810200.html](http://old.nabble.com/RabbitMQ-2.7.0-is-released-ts32810200.html) > > And bugfix so : > > > > - could not declare a mirrored queue with a policy of "nodes" and an > > explicit > > list of node names > > > > Cheers, > > > > -- > > Damien ---
**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:** [December 7, 2011, 4:06pm UTC](https://discuss.elastic.co/t/patch-for-rabbitmq-river/6079/6 "2011-12-07T16:06:51Z")
I don't care. It's yours ๐Ÿ™‚ Sounds good to me btw. 2011/12/7 Shay Banon [kimchy@gmail.com](mailto:kimchy@gmail.com) > btw, tell me if you want 1.1.0 release, its simple now that its outside of > elasticsearch :). > > On Wed, Dec 7, 2011 at 5:49 PM, Shay Banon [kimchy@gmail.com](mailto:kimchy@gmail.com) wrote: > > > cool, upgraded to 2.7.0 as well as pulling your change. > > > > On Wed, Dec 7, 2011 at 12:42 PM, Damien Hardy [damienhardy.bal@gmail.com](mailto:damienhardy.bal@gmail.com)wrote: > > > > > Hello, > > > > > > pull request applied : > > > [- add extra args to support ha queue by dhardy92 ยท Pull Request #1 ยท elastic/elasticsearch-river-rabbitmq ยท GitHub](https://github.com/elasticsearch/elasticsearch-river-rabbitmq/pull/1) > > > > > > Good news ๐Ÿ™‚ RabbitMQ 2.7.0 is out > > > [http://old.nabble.com/RabbitMQ-2.7.0-is-released-ts32810200.html](http://old.nabble.com/RabbitMQ-2.7.0-is-released-ts32810200.html) > > > And bugfix so : > > > > > > - could not declare a mirrored queue with a policy of "nodes" and an > > > explicit > > > list of node names > > > > > > Cheers, > > > > > > -- > > > Damien ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [July 6, 2017, 3:46am UTC](https://discuss.elastic.co/t/patch-for-rabbitmq-river/6079/7 "2017-07-06T03:46:11Z")