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