Revert "test."

This reverts commit 7f54bce.

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -284,17 +284,16 @@ def scan(logstash_queue)
     start_table_copy_thread
 
     scan_queue = @logstash_writer.getQueue()
-    # while !$exit
-    #   if !scan_queue.empty?
-    while true
+    while !$exit
+      if !scan_queue.empty?
         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
 
@@ -303,14 +302,13 @@ def stream(logstash_queue)
     @logger.info("Starting stream...")
     start_kcl_thread
 
-    # while !$exit
-    while true
-      # if [email protected]?
+    while !$exit
+      if !@queue.empty?
         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