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 <[email protected] <javascript:>> 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 <https://twitter.com/dadoonet> |
>> @elasticsearchfr<https://twitter.com/elasticsearchfr>
>>
>>
>> Le 19 février 2014 à 13:56:11, Doru Sular ([email protected]) 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 [email protected].
>> To view this discussion on the web visit
>> 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.
>>
>> --
> 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 [email protected] <javascript:>.
> To view this discussion on the web visit
> 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.
>
>
--
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 [email protected].
To view this discussion on the web visit
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.
