class LogStash::Inputs::Tcp
Public Class Methods
new(url, type, config={}, &block)
click to toggle source
Calls superclass method
LogStash::Inputs::Base::new
# File lib/logstash/inputs/tcp.rb, line 8 def initialize(url, type, config={}, &block) super end
Public Instance Methods
receive(host, port, event)
click to toggle source
# File lib/logstash/inputs/tcp.rb, line 25 def receive(host, port, event) url = @url.clone url.host = host url.port = port @logger.debug(["original url", { :originalurl => @url, :newurl => url }]) event = LogStash::Event.new({ "@message" => event, "@type" => @type, "@tags" => @tags.clone, }) event.source = url @logger.debug(["Got event", event]) @callback.call(event) end
register()
click to toggle source
# File lib/logstash/inputs/tcp.rb, line 13 def register 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 @logger.info("Starting tcp listener for #{@url}") EventMachine::start_server(@url.host, @url.port, TCPInput, @url, self, @logger) end