test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -285,7 +285,7 @@ def scan(logstash_queue)
     start_table_copy_thread
 
     scan_queue = @logstash_writer.getQueue()
-    while !$exit
+    while !$exit?
       event = scan_queue.take()
       if event.getEntry().nil? and event.getSize() == -1
         break
@@ -299,7 +299,7 @@ def stream(logstash_queue)
     @logger.log("Starting stream...")
     start_kcl_thread
 
-    while !$exit
+    while !$exit?
       event = @queue.pop()
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # while true