fwd.rb in fwd-0.3.2

- old
+ new

@@ -15,11 +15,13 @@
 
     attr_writer :logger
 
     # [Logger] logger instance
     def logger
-      @logger ||= ::Logger.new(STDOUT)
+      @logger ||= ::Logger.new(STDOUT).tap do |l|
+        l.level = ::Logger::INFO
+      end
     end
 
   end
 
   # @attr_reader [URI] uri to bind to
@@ -41,11 +43,11 @@
   # @param [Hash] opts
   # @option opts [String]  path path where buffer files are stored
   # @option opts [String]  prefix buffer file prefix
   # @option opts [URI] bind the endpoint to listen to
   # @option opts [Array<URI>] forward the endpoints to forward to
-  # @option opts [Integer] flush_limit flush after L messages
-  # @option opts [Integer] flush_rate flush after M messages
+  # @option opts [Integer] buffer_limit limit buffer files to N bytes
+  # @option opts [Integer] flush_rate flush after N messages
   # @option opts [Integer] flush_interval flush after N seconds
   def initialize(opts = {})
     @bind   = URI.parse(opts[:bind] || "tcp://0.0.0.0:7289")
     @root   = Pathname.new(opts[:path] || "tmp")
     @prefix = opts[:prefix] || "buffer"