test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -192,7 +192,9 @@ def run(logstash_queue)
 
   public
   def stop
+    @logger.log("exiting threads");
     exit_threads
+    @logger.log("threads exited");
     until @queue.empty?
       @logger.log("Flushing rest of events in logstash queue")
       event = @queue.pop()