Merge pull request #14 from darwin67/fix-missing-variables

Fix for missing variable bug

Author: atomita

Gemfile

@@ -5,4 +5,4 @@ gemspec
 
 gem 'fluent-plugin-elasticsearch', '~> 1.0', require: false
 gem 'aws-sdk', '~> 2', require: false
-gem 'faraday_middleware-aws-signers-v4', '>= 0.1.0, < 0.1.2', require: false
+gem 'faraday_middleware-aws-signers-v4', '>= 0.1.0', '< 0.1.2', require: false

lib/fluent/plugin/out_aws-elasticsearch-service.rb

@@ -26,7 +26,7 @@ class AwsElasticsearchServiceOutput < ElasticsearchOutput
     #
     def get_connection_options
       raise "`endpoint` require." if @endpoint.empty?
-      
+
       hosts =
         begin
           @endpoint.map do |ep|
@@ -40,11 +40,11 @@ def get_connection_options
               :credentials => credentials(ep),
               :region => ep[:region]
             }
-            
+
             host
           end
         end
-      
+
       {
         hosts: hosts
       }
@@ -60,7 +60,7 @@ def credentials(opts)
       calback = lambda do
         credentials = nil
         unless opts[:access_key_id].empty? or opts[:secret_access_key].empty?
-          credentials = Aws::Credentials.new access_key, secret_key
+          credentials = Aws::Credentials.new opts[:access_key_id], opts[:secret_access_key]
         else
           if opts[:assume_role_arn].nil?
             credentials = Aws::SharedCredentials.new({