class LogStash::Outputs::Stomp

Attributes

url[R]

Public Class Methods

new(url, config={}, &block) click to toggle source
Calls superclass method LogStash::Outputs::Base::new
# File lib/logstash/outputs/stomp.rb, line 9
def initialize(url, config={}, &block)
  super

  @logger.debug(["Initialize", { :url => @url }])
end

Public Instance Methods

receive(event) click to toggle source
# File lib/logstash/outputs/stomp.rb, line 22
def receive(event)
  @logger.debug(["Sending event", { :url => @url, :event => event }])
  @connection.send(@url.path, event.to_json)
end
register() click to toggle source
# File lib/logstash/outputs/stomp.rb, line 16
def register
  @logger.info(["Registering output", { :url => @url }])
  @connection = EventMachine::connect(@url.host, @url.port, LogStash::Stomp::Handler, self, @logger, @url)
end