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