github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

- fix bad 'source' url (LOGSTASH-821, #306)

Browse source
This commit is contained in:
Jordan Sissel 2013-01-09 23:04:15 -08:00
parent 369fa3a18b
commit 0640935fd7
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
lib/logstash/inputs/zeromq.rb
View file

@ -1,6 +1,7 @@
require "logstash/inputs/base" require "logstash/inputs/base"
require "logstash/namespace" require "logstash/namespace"
require "timeout" require "timeout"
require "socket"
# Read events over a 0MQ SUB socket. # Read events over a 0MQ SUB socket.
# #
@ -119,6 +120,7 @@ class LogStash::Inputs::ZeroMQ < LogStash::Inputs::Base
end # def server? end # def server?
def run(output_queue) def run(output_queue)
host = Socket.gethostname
begin begin
loop do loop do
# Here's the unified receiver # Here's the unified receiver
@ -138,7 +140,7 @@ class LogStash::Inputs::ZeroMQ < LogStash::Inputs::Base
@logger.debug("ZMQ receiving", :event => m2) @logger.debug("ZMQ receiving", :event => m2)
msg = m2 msg = m2
end end
@sender ||= "zmq+#{@topology}://#{@type}/" @sender ||= "zmq+#{@topology}://#{host}/#{@type}"
e = self.to_event(msg, @sender) e = self.to_event(msg, @sender)
if e if e
output_queue << e output_queue << e