diff --git a/lib/fluent/plugin/in_sqs.rb b/lib/fluent/plugin/in_sqs.rb index f808316..81609bc 100644 --- a/lib/fluent/plugin/in_sqs.rb +++ b/lib/fluent/plugin/in_sqs.rb @@ -21,12 +21,6 @@ class SQSInput < Input def configure(conf) super - - Aws.config = { - access_key_id: @aws_key_id, - secret_access_key: @aws_sec_key, - region: @region - } end def start @@ -36,7 +30,12 @@ def start end def client - @client ||= Aws::SQS::Client.new(stub_responses: @stub_responses) + @client ||= Aws::SQS::Client.new( + access_key_id: @aws_key_id, + secret_access_key: @aws_sec_key, + region: @region, + stub_responses: @stub_responses, + ) end def queue diff --git a/lib/fluent/plugin/out_sqs.rb b/lib/fluent/plugin/out_sqs.rb index dcd2bcc..4501277 100644 --- a/lib/fluent/plugin/out_sqs.rb +++ b/lib/fluent/plugin/out_sqs.rb @@ -33,15 +33,14 @@ def configure(conf) compat_parameters_convert(conf, :buffer, :inject) super - Aws.config = { - access_key_id: @aws_key_id, - secret_access_key: @aws_sec_key, - region: @region - } end def client - @client ||= Aws::SQS::Client.new + @client ||= Aws::SQS::Client.new( + access_key_id: @aws_key_id, + secret_access_key: @aws_sec_key, + region: @region + ) end def resource