class LogStash::Outputs::Tcp::Client
Public Class Methods
new(socket, logger)
click to toggle source
# File lib/logstash/outputs/tcp.rb, line 44 def initialize(socket, logger) @socket = socket @logger = logger @queue = Queue.new end
Public Instance Methods
run()
click to toggle source
# File lib/logstash/outputs/tcp.rb, line 51 def run loop do begin @socket.write(@queue.pop) rescue => e @logger.warn("tcp output exception", :socket => @socket, :exception => e) break end end end
write(msg)
click to toggle source
# File lib/logstash/outputs/tcp.rb, line 64 def write(msg) @queue.push(msg) end