Skip to content

Commit ade95c0

Browse files
authored
Revert "Add SNS event support"
1 parent decee99 commit ade95c0

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

lib/fluent/plugin/in_s3.rb

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -104,8 +104,6 @@ def initialize
104104
config_param :wait_time_seconds, :integer, default: 20
105105
desc "Polling error retry interval."
106106
config_param :retry_error_interval, :integer, default: 300
107-
desc "Assume messages as SNS notifications"
108-
config_param :assume_sns, :bool, default: false
109107
end
110108

111109
desc "Tag string"
@@ -184,10 +182,6 @@ def run
184182
begin
185183
body = Yajl.load(message.body)
186184
log.debug(body)
187-
if @assume_sns
188-
next unless body["Message"]
189-
body = Yajl.load(body["Message"])
190-
end
191185
next unless body["Records"] # skip test queue
192186

193187
process(body)

0 commit comments

Comments
 (0)