test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -193,6 +193,7 @@ def run(logstash_queue)
   public
   def stop
     @logger.log("exiting threads");
+    @something = true
     exit_threads
     @logger.log("threads exited");
     until @queue.empty?
@@ -303,7 +304,7 @@ def stream(logstash_queue)
     @logger.warn("Started KCL thread")
 
     while @something == false
-    @logger.warn("Looping KCL thread #{@something}")
+    #@logger.warn("Looping KCL thread #{@something}")
 
       if !@queue.empty?
         event = @queue.pop()