How to change configuration parameters for RabbitMQ River?

Elastic Stack Elasticsearch
1

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

2

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 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

3

Thanks for reply.previously i had posted question "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/
1228782],but it flop when Rabbitmq server on other machine.i try
following code[unable to create index using rabbitmq river? · GitHub] but i stuck.

On Sep 20, 1:43 pm, Shay Banon 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 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

4

Thanks for reply.previously i had posted question
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/
1228782],but it flop when Rabbitmq server on other machine.i try
following code[unable to create index using rabbitmq river? · GitHub] but i stuck.
On Sep 20, 1:43 pm, Shay Banon 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 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