class LogStash::Outputs::Tcp
Public Instance Methods
receive(event)
click to toggle source
# File lib/logstash/outputs/tcp.rb, line 18 def receive(event) @connection.send_data(event.to_hash.to_json) @connection.send_data("\n") end
register()
click to toggle source
# File lib/logstash/outputs/tcp.rb, line 6 def register # TODO(sissel): Write generic validation methods if !@url.host or !@url.port @logger.fatal("No host or port given in #{self.class}: #{@url}") # TODO(sissel): Make this an actual exception class raise "configuration error" end @connection = EventMachine::connect(@url.host, @url.port) end