file_repository.rb in logstash-output-s3-4.3.6

- old
+ new

@@ -2,12 +2,10 @@
 require "java"
 require "concurrent"
 require "concurrent/timer_task"
 require "logstash/util"
 
-ConcurrentHashMap = java.util.concurrent.ConcurrentHashMap
-
 module LogStash
   module Outputs
     class S3
       class FileRepository
         DEFAULT_STATE_SWEEPER_INTERVAL_SECS = 60
@@ -57,10 +55,10 @@
         def initialize(tags, encoding, temporary_directory,
                        stale_time = DEFAULT_STALE_TIME_SECS,
                        sweeper_interval = DEFAULT_STATE_SWEEPER_INTERVAL_SECS)
           # The path need to contains the prefix so when we start
           # logtash after a crash we keep the remote structure
-          @prefixed_factories =  ConcurrentHashMap.new
+          @prefixed_factories = java.util.concurrent.ConcurrentHashMap.new
 
           @sweeper_interval = sweeper_interval
 
           @factory_initializer = FactoryInitializer.new(tags, encoding, temporary_directory, stale_time)
 