fix queue name

datacite · Jun 16, 2020 · ba28ba3 · ba28ba3
1 parent 98d5d26
commit ba28ba3
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/app/models/concerns/indexable.rb b/app/models/concerns/indexable.rb
@@ -56,7 +56,12 @@ def send_import_message(data)
     # we use the AWS SQS client directly as there is no consumer in this app
     def send_message(body, options={})
       sqs = Aws::SQS::Client.new
-      queue_url = sqs.get_queue_url(queue_name: "#{Rails.env}_doi").queue_url
+      if Rails.env == "stage" 
+        queue_name_prefix = ENV['ES_PREFIX'].present? ? "stage" : "test"
+      else
+        queue_name_prefix = Rails.env
+      end
+      queue_url = sqs.get_queue_url(queue_name: "#{queue_name_prefix}_doi").queue_url
       options[:shoryuken_class] ||= "DoiImportWorker"
 
       options = {