Kouhei Sutou
null+****@clear*****
Fri Dec 20 15:25:53 JST 2013
Kouhei Sutou 2013-12-20 15:25:53 +0900 (Fri, 20 Dec 2013) New Revision: ec959bc3a32590a7deeec30f3619feb2434e1244 https://github.com/droonga/fluent-plugin-droonga/commit/ec959bc3a32590a7deeec30f3619feb2434e1244 Message: collector: don't use "command" when a message is received Modified files: lib/droonga/collector.rb Modified: lib/droonga/collector.rb (+1 -3) =================================================================== --- lib/droonga/collector.rb 2013-12-20 15:24:34 +0900 (8018d04) +++ lib/droonga/collector.rb 2013-12-20 15:25:53 +0900 (6af12e0) @@ -92,10 +92,9 @@ module Droonga task["n_of_inputs"] += 1 component = task["component"] type = component["type"] - command = component["command"] || ("collector_" + type) + command = "collector_" + type n_of_expects = component["n_of_expects"] synchronous = nil - if command synchronous = true unless n_of_expects.zero? # TODO: check if asynchronous execution is available. message = { @@ -120,7 +119,6 @@ module Droonga else @dispatcher.deliver(@id, task["route"], message, command, synchronous) end - end return if task["n_of_inputs"] < n_of_expects #the task is done if synchronous -------------- next part -------------- HTML����������������������������...Download
