test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -285,7 +285,7 @@ def scan(logstash_queue)
 
     scan_queue = @logstash_writer.getQueue()
     while !$exit
-      if !@queue.empty?
+      if !@scan_queue.empty?
         event = scan_queue.take()
         @logger.warn("got event...")
         if event.getEntry().nil? and event.getSize() == -1