Kouhei Sutou
null+****@clear*****
Thu Mar 28 16:41:24 JST 2013
Kouhei Sutou 2013-03-28 16:41:24 +0900 (Thu, 28 Mar 2013) New Revision: 81427161ed4f3ce2534b9e8565d4437b3fd9c2e5 https://github.com/groonga/fluent-plugin-droonga/commit/81427161ed4f3ce2534b9e8565d4437b3fd9c2e5 Message: Add a test for replyTo parameter Modified files: lib/fluent/plugin/out_droonga.rb Modified: lib/fluent/plugin/out_droonga.rb (+5 -2) =================================================================== --- lib/fluent/plugin/out_droonga.rb 2013-03-28 16:25:29 +0900 (3fc0861) +++ lib/fluent/plugin/out_droonga.rb 2013-03-28 16:41:24 +0900 (bf0d4fa) @@ -74,8 +74,7 @@ module Fluent connection_id = $1 if not has_connection_id or output[:connection_id] != connection_id output[:connection_id] = connection_id - logger = Fluent::Logger::FluentLogger.new(tag, :host => host, - :port=> port.to_i) + logger = create_logger(tag, :host => host, :port => port.to_i) # output[:logger] should be closed if it exists beforehand? output[:logger] = logger end @@ -111,5 +110,9 @@ module Fluent def create_worker Droonga::Worker.new(@database, @queue_name) end + + def create_logger(tag, options) + Fluent::Logger::FluentLogger.new(tag, options) + end end end -------------- next part -------------- HTML����������������������������...Télécharger
