test.

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -284,16 +284,17 @@ def scan(logstash_queue)
     start_table_copy_thread
 
     scan_queue = @logstash_writer.getQueue()
-    while !$exit
-      if !scan_queue.empty?
+    # while !$exit
+    #   if !scan_queue.empty?
+    while true
         event = scan_queue.take()
         if event.getEntry().nil? and event.getSize() == -1
           break
         end # if event.isEmpty()
         queue_event(@parser.parse_scan(event.getEntry(), event.getSize()), logstash_queue, @host)
-      else
-        sleep(0.01)
-      end
+      # else
+      #   sleep(0.01)
+      # end
     end # while true
   end
 
@@ -302,13 +303,14 @@ def stream(logstash_queue)
     @logger.info("Starting stream...")
     start_kcl_thread
 
-    while !$exit
-      if !@queue.empty?
+    # while !$exit
+    while true
+      # if [email protected]?
         event = @queue.pop()
         queue_event(@parser.parse_stream(event), logstash_queue, @host)
-      else
-        sleep(0.01)
-      end
+      # else
+      #   sleep(0.01)
+      # end
     end # while true
   end