Sha256: b3d7ade59cd59e86a1d28eb4640175e32a804949c7f17541f2fc25bfb8828273
Contents?: true
Size: 675 Bytes
Versions: 4
Compression:
Stored size: 675 Bytes
Contents
# encoding: utf-8
require "logstash/outputs/base"
require "thread"
class DummyOutput < LogStash::Outputs::Base
config_name "dummyoutput"
milestone 2
attr_reader :num_closes, :events
def initialize(params={})
super
@num_closes = 0
@events = Queue.new
end
def register
end
def receive(event)
@events << event
end
def close
@num_closes = 1
end
end
class DummyOutputWithEventsArray < LogStash::Outputs::Base
config_name "dummyoutput2"
milestone 2
attr_reader :events
def initialize(params={})
super
@events = []
end
def register
end
def receive(event)
@events << event
end
def close
end
end
Version data entries
4 entries across 4 versions & 2 rubygems