Hello everybody, I intend to use ActiveMQ river and elasticsearch integrated in the same JVM. In the ActiveMQ river installation guide is mention the following command bin/plugin -install domdorn/elasticsearch-river-activemq/1.0. What should I do to have the same effect from java code? I want to…

I guess you just need to add the river jar and its dependencies in your class path. If you use Maven, it should be very easy. -- David Pilato | Technical Advocate | Elasticsearch.com @dadoonet | @elasticsearchfr Le 19 février 2014 à 13:56:11, Doru Sular ( doru.sular@gmail.com ) a écrit: Hello ev…

That's all? I don't need any ES api calls? I will try it soon, thank you very much! Doru On Wednesday, February 19, 2014 3:55:40 PM UTC+1, David Pilato wrote: I guess you just need to add the river jar and its dependencies in your class path. If you use Maven, it should be very easy. -- Dav…

As soon as the jar file have a es-plugin.properties file, it will be loaded by the node. Of course, you will need then to create the river itself which will require one API Call (prepareIndex). -- David :wink: Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs Le 19 févr. 2014 à 17:07, Doru …

Hi David I have successfully created the riever, unfortunatelly the the documents are not stored in the index I specify. I can see via debugger that the messages are taken from the queue, but the bulk request is failing, Here is my confdiguration: public void createRiver() { try { XContentB…

What say logs? -- David :wink: Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs Le 20 févr. 2014 à 13:00, Doru Sular doru.sular@gmail.com a écrit : Hi David I have successfully created the riever, unfortunatelly the the documents are not stored in the index I specify. I can see via debug…

The exception is: "org.elasticsearch.action.ActionRequestValidationException: Validation Failed: 1: no requests added;" I have the feeling that the messages in queue should be alternante: { "index" : { "_index" : "twitter", "_type" : "tweet", "_id" : "1" } } { "tweet" : { "text" : "this is firs…

No you can not have the later format. Check Bulk API docs: http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/docs-bulk.html Don't forget the last \n char BTW. -- David Pilato | Technical Advocate | Elasticsearch.com @dadoonet | @elasticsearchfr Le 20 février 2014 à 14:51:23…

Thank you very much, I will try again. Doru On Thursday, February 20, 2014 3:00:58 PM UTC+1, David Pilato wrote: No you can not have the later format. Check Bulk API docs: Elasticsearch Platform — Find real-time answers at scale | Elastic Don't forget the last \n char BTW. -- David Pilato |…

Discuss the Elastic Stack

Integrate (Install) ActiveMQ river in embedded elastic search

Elastic Stack Elasticsearch

Topic		Replies	Views
ActiveMQ River Configuration Elasticsearch	8	1066	July 6, 2017
ElasticSearch and RabbitMQ as data source Elasticsearch	8	1435	July 6, 2017
How to create RabbitMq River using java api? Elasticsearch	5	407	July 6, 2017
Announce: ActiveMQ River Elasticsearch	2	305	July 6, 2017
How to implement RabbitMQ River using java? Elasticsearch	5	540	July 6, 2017

Elasticsearch is a trademark of Elasticsearch BV, registered in the U.S. and in other countries
Trademarks
Terms
Privacy
Brand
Code of Conduct

Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant logo are trademarks of the Apache Software Foundation in the United States and/or other countries.

Integrate (Install) ActiveMQ river in embedded elastic search

Related topics