From e254f48309e81c478438910bc6092683579c32ae Mon Sep 17 00:00:00 2001 From: Mikhail Nelaev Date: Fri, 15 Apr 2016 11:10:51 +0500 Subject: [PATCH] =?UTF-8?q?feature:=20=D0=BF=D0=BE=D0=B4=D0=B0=D0=B2=D0=BB?= =?UTF-8?q?=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=BE=D1=88=D0=B8=D0=B1=D0=BE=D0=BA?= =?UTF-8?q?=20resque-retry?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit https://jira.railsc.ru/browse/SERVICES-766 https://jira.railsc.ru/browse/SERVICES-656 --- lib/resque/integration/engine.rb | 12 ++++++++++++ resque-integration.gemspec | 2 +- 2 files changed, 13 insertions(+), 1 deletion(-) diff --git a/lib/resque/integration/engine.rb b/lib/resque/integration/engine.rb index 64ca9e5..77b071d 100644 --- a/lib/resque/integration/engine.rb +++ b/lib/resque/integration/engine.rb @@ -65,6 +65,18 @@ class Engine < Rails::Engine end end + # Глушим ошибки, по которым происходит автоматический перезапуск + initializer 'resque-integration.retrys' do + if Resque.config.failure_notifier.enabled? + require 'resque_failed_job_mailer' + require 'resque/failure' + require 'resque/failure/redis' + + Resque::Failure::MultipleWithRetrySuppression.classes = [Resque::Failure::Redis, Resque::Failure::Notifier] + Resque::Failure.backend = Resque::Failure::MultipleWithRetrySuppression + end + end + initializer "resque-integration.extensions" do ::Resque::Worker.send :include, ::Resque::Integration::Extensions::Worker end diff --git a/resque-integration.gemspec b/resque-integration.gemspec index 37f711d..c5a3491 100644 --- a/resque-integration.gemspec +++ b/resque-integration.gemspec @@ -27,7 +27,7 @@ Gem::Specification.new do |gem| gem.add_runtime_dependency 'resque-multi-job-forks', '~> 0.4.2' gem.add_runtime_dependency 'resque-failed-job-mailer', '~> 0.0.3' gem.add_runtime_dependency 'resque-scheduler', '~> 4.0' - gem.add_runtime_dependency 'resque-retry', '~> 1.3' + gem.add_runtime_dependency 'resque-retry', '~> 1.5' gem.add_runtime_dependency 'god', '~> 0.13.4' gem.add_runtime_dependency 'multi_json'