From 127133c76da4d13764d7ecffb8bac55b1815cf0e Mon Sep 17 00:00:00 2001 From: Trey Pendragon Date: Tue, 17 Sep 2019 10:20:01 -0700 Subject: [PATCH] Use environment specific retry queue. --- app/workers/figgy_event_handler.rb | 2 +- spec/workers/figgy_event_handler_spec.rb | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/app/workers/figgy_event_handler.rb b/app/workers/figgy_event_handler.rb index 1368a13e..e6c7e922 100644 --- a/app/workers/figgy_event_handler.rb +++ b/app/workers/figgy_event_handler.rb @@ -2,7 +2,7 @@ class FiggyEventHandler include Sneakers::Worker from_queue :"pomegranate_#{Rails.env}", WORKER_OPTIONS.merge( - arguments: { 'x-dead-letter-exchange': 'pomegranate-retry' } + arguments: { 'x-dead-letter-exchange': "pomegranate_#{Rails.env}-retry" } ) def work(msg) diff --git a/spec/workers/figgy_event_handler_spec.rb b/spec/workers/figgy_event_handler_spec.rb index 74763778..73abc509 100644 --- a/spec/workers/figgy_event_handler_spec.rb +++ b/spec/workers/figgy_event_handler_spec.rb @@ -35,5 +35,8 @@ expect(FiggyEventProcessor).to have_received(:new).with(msg) expect(handler).to have_received(:ack!) end + it "is configured to use an environment specific deadletter queue" do + expect(described_class.queue_opts[:arguments][:"x-dead-letter-exchange"]).to eq "pomegranate_test-retry" + end end end