How to implement RabbitMQ River using java?

Elastic Stack Elasticsearch
1

Hi

How to implement RabbitMQ River using Java?please provide detail
information ,what are the configuration required to use Rabbitmq in
elastic search.

Thanks

2

Start the most recent version of rabbitmq, then follow the ES docs at
http://www.elasticsearch.com/docs/elasticsearch/river/rabbitmq/ to create
the river. The queue/exchange will be created by rabbit automatically when
you start ES.

Regards,
Rich

On Tue, Dec 21, 2010 at 1:53 AM, sam mishra.sameek@gmail.com wrote:

Hi

How to implement RabbitMQ River using Java?please provide detail
information ,what are the configuration required to use Rabbitmq in
Elasticsearch.

Thanks

--
“We can't solve problems by using the same kind of thinking we used when we
created them.” ~ Albert Einstein

3

thanks for reply.

I am putting message on queue and also install Rabbitmq river
plugin .if i am correct this plugin is used to read queue and index.
my question is how i am able to used this plugin in my code and what
are the configuration is require to read queue and index using Java.

Thanks

On Dec 21, 8:04 pm, Rich Kroll kroll.r...@gmail.com wrote:

Start the most recent version of rabbitmq, then follow the ES docs athttp://www.elasticsearch.com/docs/elasticsearch/river/rabbitmq/to create
the river. The queue/exchange will be created by rabbit automatically when
you start ES.

Regards,
Rich

On Tue, Dec 21, 2010 at 1:53 AM, sam mishra.sam...@gmail.com wrote:

Hi

How to implement RabbitMQ River using Java?please provide detail
information ,what are the configuration required to use Rabbitmq in
Elasticsearch.

Thanks

--
“We can't solve problems by using the same kind of thinking we used when we
created them.” ~ Albert Einstein

4

Please see the RabbitMQ river documentation for the configuration of the
river: http://www.elasticsearch.com/docs/elasticsearch/river/rabbitmq/

To "use" the plugin, you need to place a bulk index formatted message onto
the configured queue, then ES will read the message off the queue and index
it.

On Wed, Dec 22, 2010 at 5:15 AM, sam mishra.sameek@gmail.com wrote:

thanks for reply.

I am putting message on queue and also install Rabbitmq river
plugin .if i am correct this plugin is used to read queue and index.
my question is how i am able to used this plugin in my code and what
are the configuration is require to read queue and index using Java.

Thanks

On Dec 21, 8:04 pm, Rich Kroll kroll.r...@gmail.com wrote:

Start the most recent version of rabbitmq, then follow the ES docs
athttp://www.elasticsearch.com/docs/elasticsearch/river/rabbitmq/to create
the river. The queue/exchange will be created by rabbit automatically
when
you start ES.

Regards,
Rich

On Tue, Dec 21, 2010 at 1:53 AM, sam mishra.sam...@gmail.com wrote:

Hi

How to implement RabbitMQ River using Java?please provide detail
information ,what are the configuration required to use Rabbitmq in
Elasticsearch.

Thanks

--
“We can't solve problems by using the same kind of thinking we used when
we
created them.” ~ Albert Einstein

--
“We can't solve problems by using the same kind of thinking we used when we
created them.” ~ Albert Einstein

5

I am putting the message in the queue in has following format:

{"id":"first","keyword":"pointing"}
{"id":"second","keyword":"michael"}

Is the above format is correct?

I am instantiating the object of RabbitmqRiver,that required three
arguments:

RabbitmqRiver(RiverName riverName, RiverSettings settings, Client
client)

Code snippet for the object creation is as follows:

org.elasticsearch.common.settings.Settings settings =
ImmutableSettings.settingsBuilder().build();
java.util.Map <String,Object>map=new HashMap();

org.elasticsearch.river.RiverSettings setting=new
org.elasticsearch.river.RiverSettings (settings ,map);
setting.settings();
org.elasticsearch.river.RiverName riverName= new
RiverName("_rivertype","rabbitmqriver");

RabbitmqRiver rabbitmqRiver = new
RabbitmqRiver(riverName,setting,client);
rabbitmqRiver.start();

But its not working.
Am i following the correct approach?

On Dec 22, 5:27 pm, Rich Kroll kroll.r...@gmail.com wrote:

Please see the RabbitMQ river documentation for the configuration of the
river:http://www.elasticsearch.com/docs/elasticsearch/river/rabbitmq/

To "use" the plugin, you need to place a bulk index formatted message onto
the configured queue, then ES will read the message off the queue and index
it.

On Wed, Dec 22, 2010 at 5:15 AM, sam mishra.sam...@gmail.com wrote:

thanks for reply.

I am putting message on queue and also install Rabbitmq river
plugin .if i am correct this plugin is used to read queue and index.
my question is how i am able to used this plugin in my code and what
are the configuration is require to read queue and index using Java.

Thanks

On Dec 21, 8:04 pm, Rich Kroll kroll.r...@gmail.com wrote:

Start the most recent version of rabbitmq, then follow the ES docs
athttp://www.elasticsearch.com/docs/elasticsearch/river/rabbitmq/tocreate
the river. The queue/exchange will be created by rabbit automatically
when
you start ES.

Regards,
Rich

On Tue, Dec 21, 2010 at 1:53 AM, sam mishra.sam...@gmail.com wrote:

Hi

How to implement RabbitMQ River using Java?please provide detail
information ,what are the configuration required to use Rabbitmq in
Elasticsearch.

Thanks

--
“We can't solve problems by using the same kind of thinking we used when
we
created them.” ~ Albert Einstein

--
“We can't solve problems by using the same kind of thinking we used when we
created them.” ~ Albert Einstein