Contents

require "logstash/outputs/base"
require "logstash/stomp/handler"

class LogStash::Outputs::Stomp < LogStash::Outputs::Base
  attr_reader :url

  def initialize(url, config={}, &block)
    super

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

  def register
    @logger.info(["Registering output", { :url => @url }])
    @connection = EventMachine::connect(@url.host, @url.port, LogStash::Stomp::Handler, self, @logger, @url)
  end # def register

  def receive(event)
    @logger.debug(["Sending event", { :url => @url, :event => event }])
    @connection.send(@url.path, event.to_json)
  end # def receive
end # class LogStash::Outputs::Stomp

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
logstash-lite-0.2.20101222161646	lib/logstash/outputs/stomp.rb
logstash-lite-0.2.20101208111718	lib/logstash/outputs/stomp.rb
logstash-lite-0.2.20101207114354	lib/logstash/outputs/stomp.rb