Yoji Shidara
null+****@clear*****
Fri Oct 11 18:34:16 JST 2013
Yoji Shidara 2013-10-11 18:34:16 +0900 (Fri, 11 Oct 2013) New Revision: 3f6946a92c2cc3aadff35ce98801e03000bd5f7b https://github.com/droonga/fluent-plugin-droonga/commit/3f6946a92c2cc3aadff35ce98801e03000bd5f7b Message: Rename watch related commands feed => watch.feed watch => watch.subscribe unwatch => watch.unsubscribe Modified files: lib/droonga/adapter.rb lib/droonga/plugin/handler_watch.rb Modified: lib/droonga/adapter.rb (+5 -5) =================================================================== --- lib/droonga/adapter.rb 2013-10-11 17:11:03 +0900 (d9f07c7) +++ lib/droonga/adapter.rb 2013-10-11 18:34:16 +0900 (6732d13) @@ -62,20 +62,20 @@ module Droonga broadcast_all(request) end - command :feed + command "watch.feed" => :feed def feed(request) puts "adapter received #{request}" broadcast_all(request) end - command :watch - def watch(request) + command "watch.subscribe" => :subscribe + def subscribe(request) puts "adapter received #{request}" broadcast_all(request) end - command :unwatch - def unwatch(request) + command "watch.unsubscribe" => :unsubscribe + def unsubscribe(request) puts "adapter received #{request}" broadcast_all(request) end Modified: lib/droonga/plugin/handler_watch.rb (+5 -5) =================================================================== --- lib/droonga/plugin/handler_watch.rb 2013-10-11 17:11:03 +0900 (ec8b54a) +++ lib/droonga/plugin/handler_watch.rb 2013-10-11 18:34:16 +0900 (bd80707) @@ -22,8 +22,8 @@ module Droonga Droonga::HandlerPlugin.register("watch", self) EXACT_MATCH = false - command "watch" - def watch(request) + command "watch.subscribe" => :subscribe + def subscribe(request) subscriber, condition, query, route = parse_request(request) query_table = @context["Query"] query_record = query_table[query] @@ -48,8 +48,8 @@ module Droonga # TODO return watch result to client end - command "unwatch" - def unwatch(request) + command "watch.unsubscribe" => :unsubscribe + def unsubscribe(request) subscriber, condition, query, route = parse_request(request) query_table = @context["Query"] query_record = query_table[query] @@ -64,7 +64,7 @@ module Droonga # TODO return unwatch result to client end - command "feed" + command "watch.feed" => :feed def feed(request) targets = request["targets"] -------------- next part -------------- HTML����������������������������...Télécharger
