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