[Groonga-commit] groonga/fluent-plugin-kotoumi [master] Add "_" to queue and name

Back to archive index

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 



More information about the Groonga-commit mailing list
Back to archive index