github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

limit begin block to just parsing the received message, not handling the event

Browse source
This commit is contained in:
pete fritchman 2010-12-04 17:57:19 -08:00
parent e58aff5095
commit f2d5258115
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
lib/logstash/inputs/beanstalk.rb
View file

@ -19,14 +19,15 @@ class LogStash::Inputs::Beanstalk < LogStash::Inputs::Base
@beanstalk.each_job do |job|
begin
event = LogStash::Event.from_json(job.body)
receive(event)
@beanstalk.delete(job)
rescue => e
@logger.warn(["Trouble parsing beanstalk job",
{:error => e.message, :body => job.body,
:backtrace => e.backtrace}])
@beanstalk.bury(job, 0)
end
receive(event)
@beanstalk.delete(job)
end # @beanstalk.each_job
end # def register
end # class LogStash::Inputs::Beanstalk