test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -200,7 +200,6 @@ def stop
       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
@@ -306,8 +305,10 @@ def stream(logstash_queue)
     while @something == false
     @logger.warn("Looping KCL thread #{@something}")
 
-      event = @queue.pop()
-      queue_event(@parser.parse_stream(event), logstash_queue, @host)
+      if (!@queue.empty?) {
+        event = @queue.pop()
+        queue_event(@parser.parse_stream(event), logstash_queue, @host)
+      }
     end # while true
 
     @logger.warn("Stopping stream...")