test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -192,13 +192,13 @@ def run(logstash_queue)
 
   public
   def stop
-    $something = true
-    exit_threads
+    #exit_threads
     until @queue.empty?
       @logger.log("Flushing rest of events in logstash queue")
       event = @queue.pop()
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # until [email protected]?
+    $something = true
   end
 
   # Starts KCL app in a background thread
@@ -292,6 +292,8 @@ def scan(logstash_queue)
       end # if event.isEmpty()
       queue_event(@parser.parse_scan(event.getEntry(), event.getSize()), logstash_queue, @host)
     end # while true
+
+    @dynamodb_scan_thread.exit
   end
 
   private
@@ -304,6 +306,8 @@ def stream(logstash_queue)
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # while true
 
+    @kcl_thread.exit
+
     @logger.warn("Stopping stream...")
   end