Contents

# encoding: utf-8
require "logstash/outputs/base"
require "logstash/namespace"

# An example output that does nothing.
class LogStash::Outputs::Beanstalkd < LogStash::Outputs::Base
  config_name "beanstalkd"

  # The address of the beanstalk server
  config :host, :validate => :string, :required => true

  # The port of your beanstalk server
  config :port, :validate => :number, :default => 11300

  # The name of the beanstalk tube
  config :tube, :validate => :string, :required => true

  # The message priority (see beanstalk docs)
  config :priority, :validate => :number, :default => 65536

  # The message delay (see beanstalk docs)
  config :delay, :validate => :number, :default => 0

  # See beanstalk documentation
  config :ttr, :validate => :number, :default => 300

  public
  def register
    require "beanstalk-client"

    @beanstalk = Beanstalk::Pool.new(["#{@host}:#{@port}"])
    @beanstalk.use(@tube)
  end 

  public
  def receive(event)
    @beanstalk.put(event.to_json, @priority, @delay, @ttr)
  end # def event
end # class LogStash::Outputs::Example

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logstash-output-beanstalkd-0.9.0	lib/logstash/outputs/example.rb