InetSocketTransportAddress needs port to be a number, silly me.

This commit is contained in:
Jordan Sissel 2014-02-10 17:05:07 -08:00
parent fb18f76277
commit cebc71fc1d

View file

@ -227,7 +227,7 @@ module LogStash::Outputs::Elasticsearch
if options[:host]
client.addTransportAddress(
org.elasticsearch.common.transport.InetSocketTransportAddress.new(
options[:host], options[:port]
options[:host], options[:port].to_i
)
)
end