Kouhei Sutou
null+****@clear*****
Fri Dec 20 17:11:42 JST 2013
Kouhei Sutou 2013-12-20 17:11:42 +0900 (Fri, 20 Dec 2013) New Revision: 7cd4d6690f4c62b3d1a5fe92752aa1a28ef373c8 https://github.com/droonga/fluent-plugin-droonga/commit/7cd4d6690f4c62b3d1a5fe92752aa1a28ef373c8 Message: dispatcher: remove generic "post" method Yay! Modified files: lib/droonga/dispatcher.rb Modified: lib/droonga/dispatcher.rb (+0 -33) =================================================================== --- lib/droonga/dispatcher.rb 2013-12-20 17:10:16 +0900 (bc50c45) +++ lib/droonga/dispatcher.rb 2013-12-20 17:11:42 +0900 (877a34b) @@ -74,39 +74,6 @@ module Droonga end end - def post(body, destination=nil) - $log.trace("#{log_tag}: post: start") - unless is_route?(destination) - destination = envelope["replyTo"] - end - command = nil - receiver = nil - arguments = nil - synchronous = nil - case destination - when String - command = destination - when Hash - command = destination["type"] - receiver = destination["to"] - arguments = destination["arguments"] - synchronous = destination["synchronous"] - end - if receiver - forward(envelope.merge("body" => body), - "type" => command, - "to" => receiver, - "arguments" => arguments) - else - if command == "dispatcher" - handle(body, arguments) - elsif @output_adapter.processable?(command) - @output_adapter.process(command, body, *arguments) - end - end - $log.trace("#{log_tag}: post: done") - end - def forward(message, destination) @forwarder.forward(message, destination) end -------------- next part -------------- HTML����������������������������...다운로드
