From 0640935fd7e49c3b6f39e1557f3eed0131f80092 Mon Sep 17 00:00:00 2001 From: Jordan Sissel Date: Wed, 9 Jan 2013 23:04:15 -0800 Subject: [PATCH] - fix bad 'source' url (LOGSTASH-821, #306) --- lib/logstash/inputs/zeromq.rb | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/lib/logstash/inputs/zeromq.rb b/lib/logstash/inputs/zeromq.rb index c45c7d56b..1bc757aba 100644 --- a/lib/logstash/inputs/zeromq.rb +++ b/lib/logstash/inputs/zeromq.rb @@ -1,6 +1,7 @@ require "logstash/inputs/base" require "logstash/namespace" require "timeout" +require "socket" # Read events over a 0MQ SUB socket. # @@ -119,6 +120,7 @@ class LogStash::Inputs::ZeroMQ < LogStash::Inputs::Base end # def server? def run(output_queue) + host = Socket.gethostname begin loop do # Here's the unified receiver @@ -138,7 +140,7 @@ class LogStash::Inputs::ZeroMQ < LogStash::Inputs::Base @logger.debug("ZMQ receiving", :event => m2) msg = m2 end - @sender ||= "zmq+#{@topology}://#{@type}/" + @sender ||= "zmq+#{@topology}://#{host}/#{@type}" e = self.to_event(msg, @sender) if e output_queue << e