mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
parent
842658f3a6
commit
b5c24ae438
1 changed files with 1 additions and 1 deletions
|
@ -57,7 +57,7 @@ module LogStash; module Util
|
|||
|
||||
def initialize(queue, batch_size = 125, wait_for = 250)
|
||||
@queue = queue
|
||||
@mutex = java.util.concurrent.locks.ReentrantLock.new
|
||||
@mutex = Mutex.new
|
||||
# Note that @inflight_batches as a central mechanism for tracking inflight
|
||||
# batches will fail if we have multiple read clients in the pipeline.
|
||||
@inflight_batches = {}
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue