Kouhei Sutou
null+****@clear*****
Wed Jan 30 17:51:26 JST 2013
Kouhei Sutou 2013-01-30 17:51:26 +0900 (Wed, 30 Jan 2013) New Revision: c217800a937ca8a63214537ddc0a82dda87c04af https://github.com/groonga/fluent-plugin-kotoumi/commit/c217800a937ca8a63214537ddc0a82dda87c04af Log: Add "_" to queue and name Modified files: lib/fluent/plugin/out_kotoumi.rb lib/kotoumi/worker.rb Modified: lib/fluent/plugin/out_kotoumi.rb (+2 -2) =================================================================== --- lib/fluent/plugin/out_kotoumi.rb 2013-01-30 17:37:01 +0900 (c9262db) +++ lib/fluent/plugin/out_kotoumi.rb 2013-01-30 17:51:26 +0900 (afe87c7) @@ -24,12 +24,12 @@ module Fluent Plugin.register_output("kotoumi", self) config_param :database, :string, :default => "kotoumi.db" - config_param :queuename, :string, :default => "KotoumiQueue" + config_param :queue_name, :string, :default => "KotoumiQueue" def start super # prefork @workers - @worker = Kotoumi::Worker.new(@database, @queuename) + @worker = Kotoumi::Worker.new(@database, @queue_name) @outputs = {} end Modified: lib/kotoumi/worker.rb (+2 -2) =================================================================== --- lib/kotoumi/worker.rb 2013-01-30 17:37:01 +0900 (aa3247c) +++ lib/kotoumi/worker.rb 2013-01-30 17:51:26 +0900 (8f1c87e) @@ -19,10 +19,10 @@ require 'groonga' module Kotoumi class Worker - def initialize(database, queuename) + def initialize(database, queue_name) Groonga::Database.open(database) @ctx = Groonga::Context.default - @queuename = queuename + @queuename = queue_name end def process_message(record) -------------- next part -------------- HTML����������������������������...Download
