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