test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -192,7 +192,7 @@ def run(logstash_queue)
 
   public
   def stop
-    #exit_threads
+    exit_threads
     until @queue.empty?
       @logger.log("Flushing rest of events in logstash queue")
       event = @queue.pop()
@@ -292,8 +292,6 @@ 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
@@ -310,13 +308,13 @@ def stream(logstash_queue)
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # while true
 
-    @kcl_thread.exit
-
     @logger.warn("Stopping stream...")
   end
 
   private
   def exit_threads
+    @worker.shutdown()
+
     unless @dynamodb_scan_thread.nil?
       @dynamodb_scan_thread.exit
     end # unless @dynamodb_scan_thread.nil?