test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -277,7 +277,7 @@ def setup_stream
 
   private
   def scan(logstash_queue)
-    @logger.info("Starting scan...")
+    @logger.warn("Starting scan...")
     @logstash_writer = DynamoDBBootstrap::BlockingQueueConsumer.new(@number_of_write_threads)
 
     @connector = DynamoDBBootstrap::DynamoDBBootstrapWorker.new(@dynamodb_client, @read_ops, @table_name, @number_of_scan_threads)
@@ -287,7 +287,9 @@ def scan(logstash_queue)
     while !$exit
       if !@queue.empty?
         event = scan_queue.take()
+        @logger.warn("got event...")
         if event.getEntry().nil? and event.getSize() == -1
+          @logger.warn("event is nil")
           break
         end # if event.isEmpty()
         queue_event(@parser.parse_scan(event.getEntry(), event.getSize()), logstash_queue, @host)
@@ -299,7 +301,7 @@ def scan(logstash_queue)
 
   private
   def stream(logstash_queue)
-    @logger.info("Starting stream...")
+    @logger.warn("Starting stream...")
     start_kcl_thread
 
     while !$exit