We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents decee99 + ade95c0 commit dd6a0f2Copy full SHA for dd6a0f2
lib/fluent/plugin/in_s3.rb
@@ -104,8 +104,6 @@ def initialize
104
config_param :wait_time_seconds, :integer, default: 20
105
desc "Polling error retry interval."
106
config_param :retry_error_interval, :integer, default: 300
107
- desc "Assume messages as SNS notifications"
108
- config_param :assume_sns, :bool, default: false
109
end
110
111
desc "Tag string"
@@ -184,10 +182,6 @@ def run
184
182
begin
185
183
body = Yajl.load(message.body)
186
log.debug(body)
187
- if @assume_sns
188
- next unless body["Message"]
189
- body = Yajl.load(body["Message"])
190
- end
191
next unless body["Records"] # skip test queue
192
193
process(body)
0 commit comments