more.

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -184,18 +184,18 @@ def register
   def run(logstash_queue)
     begin
       run_with_catch(logstash_queue)
-    end
-    while !stop?
-    end
 
       @logger.warn("STOPPING!")
 
-    exit_threads
-    until @queue.empty?
-      @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]?
+      exit_threads
+      until @queue.empty?
+        @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]?
+
+      close
+    end
   end # def run(logstash_queue)
 
   # Starts KCL app in a background thread