diff --git a/lib/fog/aws/requests/kinesis/create_stream.rb b/lib/fog/aws/requests/kinesis/create_stream.rb index bfb83c83b..16c7ae12d 100644 --- a/lib/fog/aws/requests/kinesis/create_stream.rb +++ b/lib/fog/aws/requests/kinesis/create_stream.rb @@ -20,7 +20,7 @@ module Fog }.reject{ |_,v| v.nil? } response = request({ - 'X-Amz-Target' => 'Kinesis_#{@version}.CreateStream', + 'X-Amz-Target' => "Kinesis_#{@version}.CreateStream", :body => body, }.merge(options)) # response.body = Fog::JSON.decode(response.body) unless response.body.nil? diff --git a/lib/fog/aws/requests/kinesis/delete_stream.rb b/lib/fog/aws/requests/kinesis/delete_stream.rb index 5f6850eb1..f1e04ece0 100644 --- a/lib/fog/aws/requests/kinesis/delete_stream.rb +++ b/lib/fog/aws/requests/kinesis/delete_stream.rb @@ -18,7 +18,7 @@ module Fog }.reject{ |_,v| v.nil? } response = request({ - 'X-Amz-Target' => 'Kinesis_#{@version}.DeleteStream', + 'X-Amz-Target' => "Kinesis_#{@version}.DeleteStream", :body => body, }.merge(options)) # response.body = Fog::JSON.decode(response.body) unless response.body.nil? diff --git a/lib/fog/aws/requests/kinesis/describe_stream.rb b/lib/fog/aws/requests/kinesis/describe_stream.rb index 34312fc04..373812c72 100644 --- a/lib/fog/aws/requests/kinesis/describe_stream.rb +++ b/lib/fog/aws/requests/kinesis/describe_stream.rb @@ -23,7 +23,7 @@ module Fog response = request({ :idempotent => true, - 'X-Amz-Target' => 'Kinesis_#{@version}.DescribeStream', + 'X-Amz-Target' => "Kinesis_#{@version}.DescribeStream", :body => body, }.merge(options)) response.body = Fog::JSON.decode(response.body) unless response.body.nil? diff --git a/lib/fog/aws/requests/kinesis/get_records.rb b/lib/fog/aws/requests/kinesis/get_records.rb index 623dbad30..d9ad3d0e6 100644 --- a/lib/fog/aws/requests/kinesis/get_records.rb +++ b/lib/fog/aws/requests/kinesis/get_records.rb @@ -20,8 +20,7 @@ module Fog }.reject{ |_,v| v.nil? } response = request({ - :idempotent => true, - 'X-Amz-Target' => 'Kinesis_#{@version}.GetRecords', + 'X-Amz-Target' => "Kinesis_#{@version}.GetRecords", :body => body, }.merge(options)) response.body = Fog::JSON.decode(response.body) unless response.body.nil? diff --git a/lib/fog/aws/requests/kinesis/get_shard_iterator.rb b/lib/fog/aws/requests/kinesis/get_shard_iterator.rb index 9659215ba..e0b54d971 100644 --- a/lib/fog/aws/requests/kinesis/get_shard_iterator.rb +++ b/lib/fog/aws/requests/kinesis/get_shard_iterator.rb @@ -24,8 +24,7 @@ module Fog }.reject{ |_,v| v.nil? } response = request({ - :idempotent => true, - 'X-Amz-Target' => 'Kinesis_#{@version}.GetShardIterator', + 'X-Amz-Target' => "Kinesis_#{@version}.GetShardIterator", :body => body, }.merge(options)) response.body = Fog::JSON.decode(response.body) unless response.body.nil? diff --git a/lib/fog/aws/requests/kinesis/put_records.rb b/lib/fog/aws/requests/kinesis/put_records.rb index 2a605a4dc..2f70d98fb 100644 --- a/lib/fog/aws/requests/kinesis/put_records.rb +++ b/lib/fog/aws/requests/kinesis/put_records.rb @@ -24,7 +24,7 @@ module Fog }.reject{ |_,v| v.nil? } response = request({ - 'X-Amz-Target' => 'Kinesis_#{@version}.PutRecords', + 'X-Amz-Target' => "Kinesis_#{@version}.PutRecords", :body => body, }.merge(options)) response.body = Fog::JSON.decode(response.body) unless response.body.nil?