From e371313519390b3c291b906167391003470038da Mon Sep 17 00:00:00 2001 From: Tawan Sierek Date: Tue, 31 Jan 2017 20:49:01 +0100 Subject: [PATCH] Fix #50 Pass region as argument to NonExistentQueue --- lib/active_job/queue_adapters/active_elastic_job_adapter.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/active_job/queue_adapters/active_elastic_job_adapter.rb b/lib/active_job/queue_adapters/active_elastic_job_adapter.rb index 6aa5423..c5a150d 100644 --- a/lib/active_job/queue_adapters/active_elastic_job_adapter.rb +++ b/lib/active_job/queue_adapters/active_elastic_job_adapter.rb @@ -142,7 +142,7 @@ def queue_url(queue_name) resp = aws_sqs_client.get_queue_url(queue_name: queue_name.to_s) @queue_urls[cache_key] = resp.queue_url rescue Aws::SQS::Errors::NonExistentQueue => e - raise NonExistentQueue, queue_name + raise NonExistentQueue.new(queue_name, aws_region) end def calculate_delay(timestamp)