class LogStash::Outputs::Beanstalk

Public Class Methods

new(url, config={}, &block) click to toggle source
Calls superclass method LogStash::Outputs::Base::new
# File lib/logstash/outputs/beanstalk.rb, line 7
def initialize(url, config={}, &block)
  super

  @ttr = @urlopts["ttr"] || 300;
  if @url.path == "" or @url.path == "/"
    raise "must specify a tube for beanstalk output"
  end
end

Public Instance Methods

receive(event) click to toggle source
# File lib/logstash/outputs/beanstalk.rb, line 26
def receive(event)
  @beanstalk.put(event.to_json, :ttr => @ttr)
end
register() click to toggle source
# File lib/logstash/outputs/beanstalk.rb, line 17
def register
  tube = @url.path[1..-1] # Skip leading '/'
  port = @url.port || 11300
  @beanstalk = EMJack::Connection.new(:host => @url.host,
                                      :port => port,
                                      :tube => tube)
end