YUKI Hiroshi
null+****@clear*****
Wed Jan 8 11:15:32 JST 2014
YUKI Hiroshi 2014-01-08 11:15:32 +0900 (Wed, 08 Jan 2014) New Revision: 699fdf42b89efc0bc7f8ca63c6cae73bbc8eba22 https://github.com/droonga/fluent-plugin-droonga/commit/699fdf42b89efc0bc7f8ca63c6cae73bbc8eba22 Message: Use "publish" instead of "notification" Modified files: lib/droonga/plugin/handler/watch.rb test/unit/plugin/handler/test_watch.rb Modified: lib/droonga/plugin/handler/watch.rb (+4 -4) =================================================================== --- lib/droonga/plugin/handler/watch.rb 2013-12-29 12:09:03 +0900 (816496f) +++ lib/droonga/plugin/handler/watch.rb 2014-01-08 11:15:32 +0900 (6aecbd0) @@ -75,13 +75,13 @@ module Droonga def feed(message, messenger) request = message.request @watcher.feed(:targets => request["targets"]) do |route, subscribers| - notification_message = { + published_message = { "to" => subscribers, "body" => request, } - notification_message = message.raw.merge(notification_message) - messenger.forward(notification_message, - "to" => route, "type" => "watch.notification") + published_message = message.raw.merge(published_message) + messenger.forward(published_message, + "to" => route, "type" => "watch.publish") end end Modified: test/unit/plugin/handler/test_watch.rb (+1 -1) =================================================================== --- test/unit/plugin/handler/test_watch.rb 2013-12-29 12:09:03 +0900 (8236bac) +++ test/unit/plugin/handler/test_watch.rb 2014-01-08 11:15:32 +0900 (3d75513) @@ -153,7 +153,7 @@ class WatchHandlerTest < Test::Unit::TestCase }, { "to" => "localhost:23003/output", - "type" => "watch.notification", + "type" => "watch.publish", }, ], ], -------------- next part -------------- HTML����������������������������...ダウンロード
