class Resque::Failure::Logstash
Public Instance Methods
save()
click to toggle source
# File lib/resque/failure/logstash.rb, line 8 def save begin message = { exception: exception.to_s, exception_class: exception.class.to_s, backtrace: exception.backtrace, worker: worker.to_s, queue: queue, payload: payload, tags: [:resque_failure] } Restash::Conf.message_mutator.call(message) if Restash::Conf.message_mutator message.merge! Restash::Conf.extra_options Restash::Conf.logger.write(message.to_json) rescue => e puts "Failed to send to logstash: #{e.message}\n#{e.backtrace}" end end