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