class LogStash::Outputs::Beanstalkd
An example output that does nothing.
Public Instance Methods
receive(event)
click to toggle source
# File lib/logstash/outputs/beanstalkd.rb, line 35 def receive(event) @beanstalk_tube.put(event.to_json, {pri: @priority, delay: @delay, ttr: @ttr}) end
register()
click to toggle source
# File lib/logstash/outputs/beanstalkd.rb, line 28 def register require "beaneater" @beanstalk = Beaneater::Pool.new(["#{@host}:#{@port}"]) @beanstalk_tube = @beanstalk.tubes.find(@tube) end