properly handle ports when using ssl

logstash-plugins · Jul 28, 2015 · 130ee3b · 130ee3b
1 parent 02f7755
commit 130ee3b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib/logstash/inputs/elasticsearch.rb b/lib/logstash/inputs/elasticsearch.rb
@@ -127,7 +127,10 @@ def register
     end
 
     hosts = if @ssl then
-      @hosts.map { |h| { :host => h, :scheme => 'https' } }
+      @hosts.map do |h|
+        host, port = h.split(":")
+        { :host => host, :scheme => 'https', :port => port }
+      end
     else
       @hosts
     end