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

better exception logging in the beanstalk input

Browse source
This commit is contained in:
pete fritchman 2010-12-04 17:55:12 -08:00
parent f3d507676b
commit e58aff5095
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

@ -21,9 +21,10 @@ class LogStash::Inputs::Beanstalk < LogStash::Inputs::Base
event = LogStash::Event.from_json(job.body)
receive(event)
@beanstalk.delete(job)
rescue
rescue => e
@logger.warn(["Trouble parsing beanstalk job",
{:error => $!, :body => job.body}])
{:error => e.message, :body => job.body,
:backtrace => e.backtrace}])
@beanstalk.bury(job, 0)
end
end # @beanstalk.each_job