test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -184,19 +184,20 @@ def register
   def run(logstash_queue)
     begin
       run_with_catch(logstash_queue)
+    end
+  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]?
+  public
+  def stop
+    @logger.warn("STOPPING!")
 
-      close
-    end
-  end # def run(logstash_queue)
+    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]?
+  end
 
   # Starts KCL app in a background thread
   # Starts parallel scan if need be in a background thread