Kouhei Sutou
null+****@clear*****
Wed Jan 30 16:47:31 JST 2013
Kouhei Sutou 2013-01-30 16:47:31 +0900 (Wed, 30 Jan 2013) New Revision: f2b2f10b0c179e87e246403b05a4dd3480ad4a9f https://github.com/groonga/fluent-plugin-kotoumi/commit/f2b2f10b0c179e87e246403b05a4dd3480ad4a9f Log: session -> worker Modified files: lib/fluent/plugin/out_kotoumi.rb Modified: lib/fluent/plugin/out_kotoumi.rb (+2 -2) =================================================================== --- lib/fluent/plugin/out_kotoumi.rb 2013-01-30 16:47:02 +0900 (15a0f47) +++ lib/fluent/plugin/out_kotoumi.rb 2013-01-30 16:47:31 +0900 (b450fc6) @@ -28,7 +28,7 @@ module Fluent def start super # prefork @workers - @session = Kotoumi::Worker.new(@database, @queuename) + @worker = Kotoumi::Worker.new(@database, @queuename) @outputs = {} end @@ -53,7 +53,7 @@ module Fluent end def exec(tag, time, record) - result =****@sessi*****_message(tag, time, record) + result =****@worke*****_message(tag, time, record) if record["replyTo"] post(record["replyTo"], tag, { inReplyTo: record["id"], -------------- next part -------------- HTML����������������������������... Télécharger