test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -275,7 +275,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)
@@ -293,13 +293,15 @@ def scan(logstash_queue)
 
   private
   def stream(logstash_queue)
-    @logger.info("Starting stream...")
+    @logger.warn("Starting stream...")
     start_kcl_thread
 
     while !stop?
       event = @queue.pop()
       queue_event(@parser.parse_stream(event), logstash_queue, @host)
     end # while true
+
+    @logger.warn("Stopping stream...")
   end
 
   private