lib/fluent/plugin/out_sqs.rb in fluent-plugin-sqs-jamesjj-fork-3.1.0 vs lib/fluent/plugin/out_sqs.rb in fluent-plugin-sqs-jamesjj-fork-3.1.1
- old
+ new
@@ -53,9 +53,12 @@
begin
sqs_url = client.get_queue_url(queue_name: @queue_name, queue_owner_aws_account_id: @queue_owner_aws_account_id).queue_url
rescue Aws::SQS::Errors::NonExistentQueue => e
if @create_queue
sqs_url = client.create_queue(queue_name: @queue_name).queue_url
+ else
+ raise
+ end
end
@queue = Aws::SQS::Queue.new(
url: sqs_url,
client: client