test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -305,10 +305,10 @@ def stream(logstash_queue)
     while @something == false
     @logger.warn("Looping KCL thread #{@something}")
 
-      if (!@queue.empty?) {
+      if !@queue.empty?
         event = @queue.pop()
         queue_event(@parser.parse_stream(event), logstash_queue, @host)
-      }
+      end
     end # while true
 
     @logger.warn("Stopping stream...")