Sha256: 267516aa94dc9afdec0d53f5686e3ec7906c0eb3f88c299434b41568f048a7b7
Contents?: true
Size: 729 Bytes
Versions: 9
Compression:
Stored size: 729 Bytes
Contents
require "logstash/outputs/base"
require "logstash/namespace"
require "logstash/stomp/handler"
class LogStash::Outputs::Stomp < LogStash::Outputs::Base
attr_reader :url
public
def initialize(url, config={}, &block)
super
@logger.debug(["Initialize", { :url => @url }])
end # def initialize
public
def register
@logger.info(["Registering output", { :url => @url }])
@connection = EventMachine::connect(@url.host, @url.port, LogStash::Stomp::Handler, self, @logger, @url)
end # def register
public
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
9 entries across 9 versions & 1 rubygems