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