We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2c87bd5 commit 2394146Copy full SHA for 2394146
app/models/queueable.rb
@@ -13,7 +13,7 @@ def send_events_other_doi_job_message(data)
13
private
14
15
def send_message(body, options = {})
16
- sqs = get_sqs_client
+ sqs = create_sqs_client
17
queue_name_prefix = ENV["SQS_PREFIX"].presence || Rails.env
18
queue_url = sqs.get_queue_url(queue_name: "#{queue_name_prefix}_#{options[:queue_name]}").queue_url
19
@@ -33,7 +33,7 @@ def send_message(body, options = {})
33
Rails.logger.error("Failed to send message to #{queue_url}. #{error.inspect}.")
34
end
35
36
- def get_sqs_client
+ def create_sqs_client
37
if Rails.env.development?
38
Aws::SQS::Client.new(endpoint: ENV["AWS_ENDPOINT"])
39
else
0 commit comments