test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -182,7 +182,7 @@ def register
 
   public
   def run(logstash_queue)
-    $exit = false
+    $something = false
     run_with_catch(logstash_queue)
 
     while !stop?
@@ -192,7 +192,7 @@ def run(logstash_queue)
 
   public
   def stop
-    $exit = true
+    $something = true
     exit_threads
     until @queue.empty?
       @logger.log("Flushing rest of events in logstash queue")
@@ -285,7 +285,7 @@ def scan(logstash_queue)
     start_table_copy_thread
 
     scan_queue = @logstash_writer.getQueue()
-    while !$exit?
+    while !$something
       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 !$something
       event = @queue.pop()
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # while true