test.

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -185,14 +185,15 @@ def run(logstash_queue)
     begin
       run_with_catch(logstash_queue)
     end
-    if stop?
-      exit_threads
-      until @queue.empty?
-        @logger.info("Flushing rest of events in logstash queue")
-        event = @queue.pop()
-        queue_event(@parser.parse_stream(event), logstash_queue, @host)
-      end # until [email protected]?
-    end # begin
+    while !stop?
+    end
+
+    exit_threads
+    until @queue.empty?
+      @logger.info("Flushing rest of events in logstash queue")
+      event = @queue.pop()
+      queue_event(@parser.parse_stream(event), logstash_queue, @host)
+    end # until [email protected]?
   end # def run(logstash_queue)
 
   # Starts KCL app in a background thread