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