# Integrate (Install) ActiveMQ river in embedded elastic search **URL:** \ **Category:** Elasticsearch\ **Created:** [February 19, 2014, 12:56pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896 "2014-02-19T12:56:07Z")\ **Posts on this page:** 10\ **Page:** 1
**Author:** ![Doru\_Sular](https://avatars.discourse-cdn.com/v4/letter/d/e9bcb4/32.png) [@Doru\_Sular](https://discuss.elastic.co/u/Doru_Sular)\ **Post date:** [February 19, 2014, 12:56pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/1 "2014-02-19T12:56:07Z")
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 have ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. Thank you very much, Doru -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [February 19, 2014, 2:55pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/2 "2014-02-19T14:55:40Z")
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](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 19 février 2014 à 13:56:11, Doru Sular ([doru.sular@gmail.com](mailto:doru.sular@gmail.com)) a écrit: 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 have ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. Thank you very much, Doru -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.5304c5ec.74b0dc51.3861%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.5304c5ec.74b0dc51.3861%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![Doru\_Sular](https://avatars.discourse-cdn.com/v4/letter/d/e9bcb4/32.png) [@Doru\_Sular](https://discuss.elastic.co/u/Doru_Sular)\ **Post date:** [February 19, 2014, 4:07pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/3 "2014-02-19T16:07:03Z")
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. > > -- > _David Pilato_ | _Technical Advocate_ | _[Elasticsearch.com](http://Elasticsearch.com)_ > @dadoonet [https://twitter.com/dadoonet](https://twitter.com/dadoonet) | @elasticsearchfr[https://twitter.com/elasticsearchfr](https://twitter.com/elasticsearchfr) > > Le 19 février 2014 à 13:56:11, Doru Sular ([doru....@gmail.com](mailto:doru....@gmail.com)\) > a écrit: > > 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 have > ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. > > Thank you very much, > Doru > > -- > You received this message because you are subscribed to the Google Groups > "elasticsearch" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com) \. > To view this discussion on the web visit > [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com) > . > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [February 19, 2014, 6:37pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/4 "2014-02-19T18:37:58Z")
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 😉 Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs Le 19 févr. 2014 à 17:07, Doru Sular [doru.sular@gmail.com](mailto:doru.sular@gmail.com) a écrit : > 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. > > > > -- > > David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) > > @dadoonet | @elasticsearchfr > > > > Le 19 février 2014 à 13:56:11, Doru Sular ([doru....@gmail.com](mailto:doru....@gmail.com)) a écrit: > > > > > 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 have ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. > > > > > > Thank you very much, > > > Doru > > > > > > -- > > > You received this message because you are subscribed to the Google Groups "elasticsearch" group. > > > To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > > To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com). > > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > -- > You received this message because you are subscribed to the Google Groups "elasticsearch" group. > To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com). > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/3B318930-1D8F-44E9-82AD-1E95E9099A23%40pilato.fr](https://groups.google.com/d/msgid/elasticsearch/3B318930-1D8F-44E9-82AD-1E95E9099A23%40pilato.fr). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![Doru\_Sular](https://avatars.discourse-cdn.com/v4/letter/d/e9bcb4/32.png) [@Doru\_Sular](https://discuss.elastic.co/u/Doru_Sular)\ **Post date:** [February 20, 2014, 12:00pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/5 "2014-02-20T12:00:06Z")
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 { XContentBuilder riverSource = XContentFactory.jsonBuilder(). startObject() // .field("type", "activemq") // .startObject("activemq") // .field("brokerUrl", "vm://localhost") // .field("sourceType", "queue") // .field("sourceName", "elasticsearch") // .field("consumerName", "activemq\_elasticsearch\_river\_pilot\_river") // .field("durable", false) // .field("filter", "") // .endObject() // .startObject("index") // .field("name", "pilot-logs") .field("type", "messages") .field("bulk\_size", 100) // .field("bulk\_timeout", "10ms") // .endObject() // .endObject(); // main object ``` this.client.index(Requests.indexRequest("_river").type( ``` "pilot\_river").id("\_meta").source(riverSource)) .actionGet(); } catch (IOException e) { e.printStackTrace(); } } The index where I need to have my messages is called "_pilot-logs_". Do you have any suggestions? Thank you very much, Doru On Wednesday, February 19, 2014 7:37:58 PM UTC+1, David Pilato wrote: > 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 😉 > Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs > > Le 19 févr. 2014 à 17:07, Doru Sular \<[doru....@gmail.com](mailto:doru....@gmail.com) \\> a > écrit : > > 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. > > > > -- > > _David Pilato_ | _Technical Advocate_ | _[Elasticsearch.com](http://Elasticsearch.com) > > [http://Elasticsearch.com](http://Elasticsearch.com)_ > > @dadoonet [https://twitter.com/dadoonet](https://twitter.com/dadoonet) | @elasticsearchfr[https://twitter.com/elasticsearchfr](https://twitter.com/elasticsearchfr) > > > > Le 19 février 2014 à 13:56:11, Doru Sular ([doru....@gmail.com](mailto:doru....@gmail.com)) a écrit: > > > > 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 have > > ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. > > > > Thank you very much, > > Doru > > > > -- > > You received this message because you are subscribed to the Google Groups > > "elasticsearch" group. > > To unsubscribe from this group and stop receiving emails from it, send an > > email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > To view this discussion on the web visit > > [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com) > > . > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > > > -- > > You received this message because you are subscribed to the Google Groups > > "elasticsearch" group. > > To unsubscribe from this group and stop receiving emails from it, send an > > email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com) \. > > To view this discussion on the web visit > > [https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com) > > . > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [February 20, 2014, 12:13pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/6 "2014-02-20T12:13:25Z")
What say logs? -- David 😉 Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs Le 20 févr. 2014 à 13:00, Doru Sular [doru.sular@gmail.com](mailto: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 debugger that the messages are taken from the queue, but the bulk request is failing, > Here is my confdiguration: > public void createRiver() > { > try > { > XContentBuilder riverSource = XContentFactory.jsonBuilder().startObject() // > .field("type", "activemq") // > .startObject("activemq") // > .field("brokerUrl", "vm://localhost") // > .field("sourceType", "queue") // > .field("sourceName", "elasticsearch") // > .field("consumerName", "activemq\_elasticsearch\_river\_pilot\_river") // > .field("durable", false) // > .field("filter", "") // > .endObject() // > .startObject("index") // > .field("name", "pilot-logs") > .field("type", "messages") > .field("bulk\_size", 100) // > .field("bulk\_timeout", "10ms") // > .endObject() // > .endObject(); // main object > > ``` > this.client.index(Requests.indexRequest("_river").type("pilot_river").id("_meta").source(riverSource)) > .actionGet(); > } > catch (IOException e) > { > e.printStackTrace(); > } > } > > ``` > > The index where I need to have my messages is called "pilot-logs". > Do you have any suggestions? > Thank you very much, > Doru > > On Wednesday, February 19, 2014 7:37:58 PM UTC+1, David Pilato wrote: > > > 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 😉 > > Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs > > > > Le 19 févr. 2014 à 17:07, Doru Sular [doru....@gmail.com](mailto:doru....@gmail.com) a écrit : > > > > > 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. > > > > > > > > -- > > > > David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) > > > > @dadoonet | @elasticsearchfr > > > > > > > > Le 19 février 2014 à 13:56:11, Doru Sular ([doru....@gmail.com](mailto:doru....@gmail.com)) a écrit: > > > > > > > > > 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 have ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. > > > > > > > > > > Thank you very much, > > > > > Doru > > > > > > > > > > -- > > > > > You received this message because you are subscribed to the Google Groups "elasticsearch" group. > > > > > To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > > > > To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com). > > > > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > > > > > -- > > > You received this message because you are subscribed to the Google Groups "elasticsearch" group. > > > To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > > To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com). > > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > -- > You received this message because you are subscribed to the Google Groups "elasticsearch" group. > To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com). > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/DC8987A7-4436-40A3-8157-3942797CE0F8%40pilato.fr](https://groups.google.com/d/msgid/elasticsearch/DC8987A7-4436-40A3-8157-3942797CE0F8%40pilato.fr). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![Doru\_Sular](https://avatars.discourse-cdn.com/v4/letter/d/e9bcb4/32.png) [@Doru\_Sular](https://discuss.elastic.co/u/Doru_Sular)\ **Post date:** [February 20, 2014, 1:51pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/7 "2014-02-20T13:51:17Z")
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 first tweet" } } { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } { "tweet" : { "text" : "this is second tweet" } } { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } { "tweet" : { "text" : "this is third tweet" } } That's the way how bulk api is working? Each real message should be prefixed by the index command? Or I can have { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } { "tweet" : { "text" : "this is first tweet" } } { "tweet" : { "text" : "this is second tweet" } } { "tweet" : { "text" : "this is third tweet" } } ? I am a little bit confused... On Thursday, February 20, 2014 1:13:25 PM UTC+1, David Pilato wrote: > What say logs? > > -- > David 😉 > Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs > > Le 20 févr. 2014 à 13:00, Doru Sular \<[doru....@gmail.com](mailto:doru....@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 debugger that the > messages are taken from the queue, but the bulk request is failing, > Here is my confdiguration: > public void createRiver() > { > try > { > XContentBuilder riverSource = XContentFactory.jsonBuilder(). > startObject() // > .field("type", "activemq") // > .startObject("activemq") // > .field("brokerUrl", "vm://localhost") // > .field("sourceType", "queue") // > .field("sourceName", "elasticsearch") // > .field("consumerName", > "activemq\_elasticsearch\_river\_pilot\_river") // > .field("durable", false) // > .field("filter", "") // > .endObject() // > .startObject("index") // > .field("name", "pilot-logs") > .field("type", "messages") > .field("bulk\_size", 100) // > .field("bulk\_timeout", "10ms") // > .endObject() // > .endObject(); // main object > > ``` > this.client.index(Requests.indexRequest("_river").type( > > ``` > > "pilot\_river").id("\_meta").source(riverSource)) > .actionGet(); > } > catch (IOException e) > { > e.printStackTrace(); > } > } > > The index where I need to have my messages is called "_pilot-logs_". > Do you have any suggestions? > Thank you very much, > Doru > > On Wednesday, February 19, 2014 7:37:58 PM UTC+1, David Pilato wrote: > > > 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 😉 > > Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs > > > > Le 19 févr. 2014 à 17:07, Doru Sular [doru....@gmail.com](mailto:doru....@gmail.com) a écrit : > > > > 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. > > > > > > -- > > > _David Pilato_ | _Technical Advocate_ | _[Elasticsearch.com](http://Elasticsearch.com) > > > [http://Elasticsearch.com](http://Elasticsearch.com)_ > > > @dadoonet [https://twitter.com/dadoonet](https://twitter.com/dadoonet) | @elasticsearchfr[https://twitter.com/elasticsearchfr](https://twitter.com/elasticsearchfr) > > > > > > Le 19 février 2014 à 13:56:11, Doru Sular ([doru....@gmail.com](mailto:doru....@gmail.com)) a écrit: > > > > > > 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 have > > > ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. > > > > > > Thank you very much, > > > Doru > > > > > > -- > > > You received this message because you are subscribed to the Google > > > Groups "elasticsearch" group. > > > To unsubscribe from this group and stop receiving emails from it, send > > > an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > > To view this discussion on the web visit > > > [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com) > > > . > > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > > > > > -- > > > You received this message because you are subscribed to the Google Groups > > > "elasticsearch" group. > > > To unsubscribe from this group and stop receiving emails from it, send an > > > email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > > To view this discussion on the web visit > > > [https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com) > > > . > > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > > > -- > > You received this message because you are subscribed to the Google Groups > > "elasticsearch" group. > > To unsubscribe from this group and stop receiving emails from it, send an > > email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com) \. > > To view this discussion on the web visit > > [https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com) > > . > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b494f678-b864-47c6-b89f-cc45539bb891%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b494f678-b864-47c6-b89f-cc45539bb891%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [February 20, 2014, 2:00pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/8 "2014-02-20T14:00:58Z")
No you can not have the later format. Check Bulk API docs: [http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/docs-bulk.html](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](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 20 février 2014 à 14:51:23, Doru Sular ([doru.sular@gmail.com](mailto:doru.sular@gmail.com)) a écrit: 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 first tweet" } } { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } { "tweet" : { "text" : "this is second tweet" } } { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } { "tweet" : { "text" : "this is third tweet" } } That's the way how bulk api is working? Each real message should be prefixed by the index command? Or I can have { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } { "tweet" : { "text" : "this is first tweet" } } { "tweet" : { "text" : "this is second tweet" } } { "tweet" : { "text" : "this is third tweet" } } ? I am a little bit confused... On Thursday, February 20, 2014 1:13:25 PM UTC+1, David Pilato wrote: What say logs? -- David 😉 Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs Le 20 févr. 2014 à 13:00, Doru Sular [doru....@gmail.com](mailto:doru....@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 debugger that the messages are taken from the queue, but the bulk request is failing, Here is my confdiguration: public void createRiver() { try { XContentBuilder riverSource = XContentFactory.jsonBuilder().startObject() // .field("type", "activemq") // .startObject("activemq") // .field("brokerUrl", "vm://localhost") // .field("sourceType", "queue") // .field("sourceName", "elasticsearch") // .field("consumerName", "activemq\_elasticsearch\_river\_pilot\_river") // .field("durable", false) // .field("filter", "") // .endObject() // .startObject("index") // .field("name", "pilot-logs") .field("type", "messages") .field("bulk\_size", 100) // .field("bulk\_timeout", "10ms") // .endObject() // .endObject(); // main object ``` this.client.index(Requests.indexRequest("_river").type("pilot_river").id("_meta").source(riverSource)) .actionGet(); } catch (IOException e) { e.printStackTrace(); } } ``` The index where I need to have my messages is called "pilot-logs". Do you have any suggestions? Thank you very much, Doru On Wednesday, February 19, 2014 7:37:58 PM UTC+1, David Pilato wrote: 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 😉 Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs Le 19 févr. 2014 à 17:07, Doru Sular [doru....@gmail.com](mailto:doru....@gmail.com) a écrit : 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. -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 19 février 2014 à 13:56:11, Doru Sular ([doru....@gmail.com](mailto:doru....@gmail.com)) a écrit: 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 have ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. Thank you very much, Doru ## -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ## You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ## You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/b494f678-b864-47c6-b89f-cc45539bb891%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b494f678-b864-47c6-b89f-cc45539bb891%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.53060a9a.109cf92e.3fd6%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53060a9a.109cf92e.3fd6%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![Doru\_Sular](https://avatars.discourse-cdn.com/v4/letter/d/e9bcb4/32.png) [@Doru\_Sular](https://discuss.elastic.co/u/Doru_Sular)\ **Post date:** [February 20, 2014, 2:51pm UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/9 "2014-02-20T14:51:22Z")
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](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](http://Elasticsearch.com)_ > @dadoonet [https://twitter.com/dadoonet](https://twitter.com/dadoonet) | @elasticsearchfr[https://twitter.com/elasticsearchfr](https://twitter.com/elasticsearchfr) > > Le 20 février 2014 à 14:51:23, Doru Sular ([doru....@gmail.com](mailto:doru....@gmail.com)\) > a écrit: > > 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 first tweet" } } > > { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } > { "tweet" : { "text" : "this is second tweet" } } > > { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } > { "tweet" : { "text" : "this is third tweet" } } > > That's the way how bulk api is working? Each real message should be > prefixed by the index command? Or I can have > > { "index" : { "\_index" : "twitter", "\_type" : "tweet", "\_id" : "1" } } > { "tweet" : { "text" : "this is first tweet" } } > { "tweet" : { "text" : "this is second tweet" } } > { "tweet" : { "text" : "this is third tweet" } } > > ? > I am a little bit confused... > > On Thursday, February 20, 2014 1:13:25 PM UTC+1, David Pilato wrote: > > > What say logs? > > > > -- > > David 😉 > > Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs > > > > Le 20 févr. 2014 à 13:00, Doru Sular [doru....@gmail.com](mailto:doru....@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 debugger that the > > messages are taken from the queue, but the bulk request is failing, > > Here is my confdiguration: > > public void createRiver() > > { > > try > > { > > XContentBuilder riverSource = XContentFactory.jsonBuilder(). > > startObject() // > > .field("type", "activemq") // > > .startObject("activemq") // > > .field("brokerUrl", "vm://localhost") // > > .field("sourceType", "queue") // > > .field("sourceName", "elasticsearch") // > > .field("consumerName", > > "activemq\_elasticsearch\_river\_pilot\_river") // > > .field("durable", false) // > > .field("filter", "") // > > .endObject() // > > .startObject("index") // > > .field("name", "pilot-logs") > > .field("type", "messages") > > .field("bulk\_size", 100) // > > .field("bulk\_timeout", "10ms") // > > .endObject() // > > .endObject(); // main object > > > > ``` > > this.client.index(Requests.indexRequest("_river").type( > > > > ``` > > > > "pilot\_river").id("\_meta").source(riverSource)) > > .actionGet(); > > } > > catch (IOException e) > > { > > e.printStackTrace(); > > } > > } > > > > The index where I need to have my messages is called "_pilot-logs_". > > Do you have any suggestions? > > Thank you very much, > > Doru > > > > On Wednesday, February 19, 2014 7:37:58 PM UTC+1, David Pilato wrote: > > > > > 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 😉 > > > Twitter : @dadoonet / @elasticsearchfr / @scrutmydocs > > > > > > Le 19 févr. 2014 à 17:07, Doru Sular [doru....@gmail.com](mailto:doru....@gmail.com) a écrit : > > > > > > 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. > > > > > > > > ``` > > > > -- > > > > > > > > ``` > > > > > > > > _David Pilato_ | _Technical Advocate_ | _[Elasticsearch.com](http://Elasticsearch.com) > > > > [http://Elasticsearch.com](http://Elasticsearch.com)_ > > > > @dadoonet [https://twitter.com/dadoonet](https://twitter.com/dadoonet) | @elasticsearchfr[https://twitter.com/elasticsearchfr](https://twitter.com/elasticsearchfr) > > > > > > > > Le 19 février 2014 à 13:56:11, Doru Sular ([doru....@gmail.com](mailto:doru....@gmail.com)) a écrit: > > > > > > > > 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 have > > > > ActiveMQ, ActiveMQ river and Elasticsearch in the same java virtual machine. > > > > > > > > Thank you very much, > > > > Doru > > > > > > > > -- > > > > You received this message because you are subscribed to the Google > > > > Groups "elasticsearch" group. > > > > To unsubscribe from this group and stop receiving emails from it, send > > > > an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > > > To view this discussion on the web visit > > > > [https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/50d5603e-21d4-4a06-8867-87c982ba1b7c%40googlegroups.com) > > > > . > > > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > > > > > > > -- > > > > You received this message because you are subscribed to the Google > > > > Groups "elasticsearch" group. > > > > To unsubscribe from this group and stop receiving emails from it, send > > > > an email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > > > To view this discussion on the web visit > > > > [https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b9ce5266-e452-4d92-ae53-f611541dded8%40googlegroups.com) > > > > . > > > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > > > > > -- > > > You received this message because you are subscribed to the Google Groups > > > "elasticsearch" group. > > > To unsubscribe from this group and stop receiving emails from it, send an > > > email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com). > > > To view this discussion on the web visit > > > [https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b7b604d0-1676-476d-8c2c-c920c33bfa7b%40googlegroups.com) > > > . > > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). > > > > -- > > You received this message because you are subscribed to the Google Groups > > "elasticsearch" group. > > To unsubscribe from this group and stop receiving emails from it, send an > > email to [elasticsearc...@googlegroups.com](mailto:elasticsearc...@googlegroups.com) \. > > To view this discussion on the web visit > > [https://groups.google.com/d/msgid/elasticsearch/b494f678-b864-47c6-b89f-cc45539bb891%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/b494f678-b864-47c6-b89f-cc45539bb891%40googlegroups.com) > > . > > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/2a17eed0-76b0-4914-90f2-b66ea7d9cc82%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/2a17eed0-76b0-4914-90f2-b66ea7d9cc82%40googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**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, 1:48am UTC](https://discuss.elastic.co/t/integrate-install-activemq-river-in-embedded-elastic-search/15896/10 "2017-07-06T01:48:39Z")