more.

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -188,9 +188,11 @@ def run(logstash_queue)
     while !stop?
     end
 
+      @logger.warn("STOPPING!")
+
     exit_threads
     until @queue.empty?
-      @logger.info("Flushing rest of events in logstash queue")
+      @logger.warn("Flushing rest of events in logstash queue")
       event = @queue.pop()
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # until [email protected]?