Skip to content

Commit 7150699

Browse files
committed
add more info on rabbitmq river
1 parent 72582ef commit 7150699

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

guide/reference/river/rabbitmq.textile

+9-4
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ p. RabbitMQ River allows to automatically index a rabbitmq queue. The format of
1515
{ "tweet" : { "text" : "another tweet" } }
1616
</pre>
1717

18-
p. Creating the rabbitmq river is as simple as:
18+
p. Creating the rabbitmq river is as simple as (all configuration parameters are provided, with default values):
1919

2020
<pre class="prettyprint">
2121
curl -XPUT 'localhost:9200/_river/my_river/_meta' -d '{
@@ -28,16 +28,21 @@ curl -XPUT 'localhost:9200/_river/my_river/_meta' -d '{
2828
"vhost" : "/",
2929
"queue" : "elasticsearch",
3030
"exchange" : "elasticsearch",
31-
"routing_key" : "elasticsearch"
31+
"routing_key" : "elasticsearch",
32+
"exchange_type" : "direct",
33+
"exchange_durable" : true,
34+
"queue_durable" : true,
35+
"queue_auto_delete" : false
3236
},
3337
"index" : {
3438
"bulk_size" : 100,
35-
"bulk_timeout" : "10ms"
39+
"bulk_timeout" : "10ms",
40+
"ordered" : false
3641
}
3742
}'
3843
</pre>
3944

40-
p. The river is automatically bulking queue messages if the queue is overloaded, allowing for faster catchup with the messages streamed into the queue.
45+
p. The river is automatically bulking queue messages if the queue is overloaded, allowing for faster catchup with the messages streamed into the queue. The `ordered` flag allows to make sure that the messages will be indexed in the same order as they arrive in the query by blocking on the bulk request before picking up the next data to be indexed. It can also be used as a simple way to throttle indexing.
4146

4247
p. The rabbitmq river is provided as a plugin and can be installed using @plugin -install river-rabbitmq@.
4348

0 commit comments

Comments
 (0)