Permalink
Browse files

- Set cluster name if given for embedded

  • Loading branch information...
jordansissel committed Jan 31, 2012
1 parent c30da31 commit 4f1e5d0298d867361c345cb38379fa815a04eecb
Showing with 1 addition and 1 deletion.
  1. +1 −1 lib/logstash/outputs/elasticsearch.rb
@@ -114,7 +114,7 @@ def start_local_elasticsearch
builder = org.elasticsearch.node.NodeBuilder.nodeBuilder
# Disable 'local only' - LOGSTASH-277
#builder.local(true)
- # TODO(sissel): Set cluster name, etc?
+ builder.settings.put("cluster.name", @cluster) if !@cluster.nil?
builder.settings.put("http.port", @embedded_http_port)
@embedded_elasticsearch = builder.node

0 comments on commit 4f1e5d0

Please sign in to comment.