test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -182,7 +182,7 @@ def register
 
   public
   def run(logstash_queue)
-    @something = false
+   @something = false
     run_with_catch(logstash_queue)
 
     while !stop?
@@ -198,7 +198,7 @@ def stop
       event = @queue.pop()
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # until [email protected]?
-    @something = true
+   @something = true
   end
 
   # Starts KCL app in a background thread
@@ -285,7 +285,7 @@ def scan(logstash_queue)
     start_table_copy_thread
 
     scan_queue = @logstash_writer.getQueue()
-    while !@something
+    while @something == false
       event = scan_queue.take()
       if event.getEntry().nil? and event.getSize() == -1
         break
@@ -301,7 +301,11 @@ def stream(logstash_queue)
     @logger.log("Starting stream...")
     start_kcl_thread
 
-    while !@something
+    @logger.warn("Started KCL thread")
+
+    while @something == false
+    @logger.warn("Looping KCL thread #{@something}")
+
       event = @queue.pop()
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # while true