class LogStash::Inputs::Stomp
Public Class Methods
new(url, config={}, &block)
click to toggle source
Calls superclass method
LogStash::Inputs::Base::new
# File lib/logstash/inputs/stomp.rb, line 7 def initialize(url, config={}, &block) super @logger.debug(["Connecting", { :url => @url }]) end
Public Instance Methods
register()
click to toggle source
# File lib/logstash/inputs/stomp.rb, line 13 def register @logger.info(["Registering input", { :url => @url}]) EventMachine::connect(@url.host, @url.port, InputHandler, self, @logger, @url) end