Skip to content

Commit 3ae1dd5

Browse files
committed
new concurrency model :shared
Fixes #96
1 parent eabe67d commit 3ae1dd5

File tree

1 file changed

+2
-2
lines changed
  • lib/logstash/outputs

1 file changed

+2
-2
lines changed

lib/logstash/outputs/s3.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,8 @@ class LogStash::Outputs::S3 < LogStash::Outputs::Base
7979
config_name "s3"
8080
default :codec, 'line'
8181

82+
concurrency :shared
83+
8284
# S3 bucket
8385
config :bucket, :validate => :string
8486

@@ -214,8 +216,6 @@ def register
214216
# http://ruby.awsblog.com/post/Tx16QY1CI5GVBFT/Threading-with-the-AWS-SDK-for-Ruby
215217
AWS.eager_autoload!(AWS::S3)
216218

217-
workers_not_supported
218-
219219
@s3 = aws_s3_config
220220
@upload_queue = Queue.new
221221
@file_rotation_lock = Mutex.new

0 commit comments

Comments
 (0)