# How to change configuration parameters for RabbitMQ River? **URL:** \ **Category:** Elasticsearch\ **Created:** [September 20, 2011, 7:05am UTC](https://discuss.elastic.co/t/how-to-change-configuration-parameters-for-rabbitmq-river/5412 "2011-09-20T07:05:31Z")\ **Posts on this page:** 5\ **Page:** 1
**Author:** ![Sam\_4](https://avatars.discourse-cdn.com/v4/letter/s/db5fbb/32.png) [@Sam\_4](https://discuss.elastic.co/u/Sam_4)\ **Post date:** [September 20, 2011, 7:05am UTC](https://discuss.elastic.co/t/how-to-change-configuration-parameters-for-rabbitmq-river/5412/1 "2011-09-20T07:05:31Z")
Hi I have machine with Rabbitmq server called machine A and another machine having Elastic Server called machine B.one other machine C publish j'son document(which i want to index) in machine A.my index- creator class reads those message and prepare index on machine B for that i want to use Rabbitmq river ,by default it takes the following configuration: 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 }, it work well when Rabbitmq server on same machine where elastic server is install but my situation is different both servers on different machine that's way I want to know how to change default configuration for Rabbitmq river using java API. Thanks ---
**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:** [September 20, 2011, 8:43am UTC](https://discuss.elastic.co/t/how-to-change-configuration-parameters-for-rabbitmq-river/5412/2 "2011-09-20T08:43:35Z")
Can you gist the actual command you use the create the rabbitmq river? On Tue, Sep 20, 2011 at 10:05 AM, sam [mishra.sameek@gmail.com](mailto:mishra.sameek@gmail.com) wrote: > Hi > > I have machine with Rabbitmq server called machine A and another > machine having Elastic Server called machine B.one other machine C > publish j'son document(which i want to index) in machine A.my index- > creator class reads those message and prepare index on machine B for > that i want to use Rabbitmq river ,by default it takes the following > configuration: > > 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 > }, > > it work well when Rabbitmq server on same machine where elastic server > is install but my situation is different both servers on different > machine that's way I want to know how to change default configuration > for Rabbitmq river using java API. > > Thanks ---
**Author:** ![Sam\_4](https://avatars.discourse-cdn.com/v4/letter/s/db5fbb/32.png) [@Sam\_4](https://discuss.elastic.co/u/Sam_4)\ **Post date:** [September 20, 2011, 10:23am UTC](https://discuss.elastic.co/t/how-to-change-configuration-parameters-for-rabbitmq-river/5412/3 "2011-09-20T10:23:25Z")
Thanks for reply.previously i had posted question "http:// [elasticsearch-users.115913.n3.nabble.com/how-to-implement-RabbitMQ-](http://elasticsearch-users.115913.n3.nabble.com/how-to-implement-RabbitMQ-) River-using-java-td2124696.html" but i didn't get any idea about what class/command will help me to index j'son docs then i have create my own class to create index that work fine when both servers(Elastic/ Rabbitmq)are same machine because it uses default configuration.i have gist for method that create index what i used.[[https://gist.github.com/](https://gist.github.com/) 1228782],but it flop when Rabbitmq server on other machine.i try following code[[unable to create index using rabbitmq river? · GitHub](https://gist.github.com/1228803)] but i stuck. On Sep 20, 1:43 pm, Shay Banon [kim...@gmail.com](mailto:kim...@gmail.com) wrote: > Can you gist the actual command you use the create the rabbitmq river? > > On Tue, Sep 20, 2011 at 10:05 AM, sam [mishra.sam...@gmail.com](mailto:mishra.sam...@gmail.com) wrote: > > > Hi > > > I have machine with Rabbitmq server called machine A and another > > machine having Elastic Server called machine B.one other machine C > > publish j'son document(which i want to index) in machine A.my index- > > creator class reads those message and prepare index on machine B for > > that i want to use Rabbitmq river ,by default it takes the following > > configuration: > > > 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 > > }, > > > it work well when Rabbitmq server on same machine where elastic server > > is install but my situation is different both servers on different > > machine that's way I want to know how to change default configuration > > for Rabbitmq river using java API. > > > Thanks ---
**Author:** ![Sam\_4](https://avatars.discourse-cdn.com/v4/letter/s/db5fbb/32.png) [@Sam\_4](https://discuss.elastic.co/u/Sam_4)\ **Post date:** [September 20, 2011, 10:27am UTC](https://discuss.elastic.co/t/how-to-change-configuration-parameters-for-rabbitmq-river/5412/4 "2011-09-20T10:27:33Z")
Thanks for reply.previously i had posted question [http://elasticsearch-users.115913.n3.nabble.com/how-to-implement-RabbitMQ-River-using-java-td2124696.html](http://elasticsearch-users.115913.n3.nabble.com/how-to-implement-RabbitMQ-River-using-java-td2124696.html) but i didn't get any idea about what class/command will help me to index j'son docs then i have create my own class to create index that work fine when both servers(Elastic/ Rabbitmq)are same machine because it uses default configuration.i have gist for method that create index what i used.[[https://gist.github.com/](https://gist.github.com/) 1228782],but it flop when Rabbitmq server on other machine.i try following code[[unable to create index using rabbitmq river? · GitHub](https://gist.github.com/1228803)] but i stuck. On Sep 20, 1:43 pm, Shay Banon [kim...@gmail.com](mailto:kim...@gmail.com) wrote: > Can you gist the actual command you use the create the rabbitmq river? > > On Tue, Sep 20, 2011 at 10:05 AM, sam [mishra.sam...@gmail.com](mailto:mishra.sam...@gmail.com) wrote: > > > Hi > > > I have machine with Rabbitmq server called machine A and another > > machine having Elastic Server called machine B.one other machine C > > publish j'son document(which i want to index) in machine A.my index- > > creator class reads those message and prepare index on machine B for > > that i want to use Rabbitmq river ,by default it takes the following > > configuration: > > > 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 > > }, > > > it work well when Rabbitmq server on same machine where elastic server > > is install but my situation is different both servers on different > > machine that's way I want to know how to change default configuration > > for Rabbitmq river using java API. > > > Thanks ---
**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:54am UTC](https://discuss.elastic.co/t/how-to-change-configuration-parameters-for-rabbitmq-river/5412/5 "2017-07-06T03:54:03Z")