Kouhei Sutou
null+****@clear*****
Fri May 2 15:35:09 JST 2014
Kouhei Sutou 2014-05-02 15:35:09 +0900 (Fri, 02 May 2014) New Revision: a2d6283d64a07c103f448909ea9cfc76c4907681 https://github.com/droonga/droonga-client-ruby/commit/a2d6283d64a07c103f448909ea9cfc76c4907681 Message: Set "replyTo" to subscribe message Modified files: lib/droonga/client/connection/droonga-protocol/coolio.rb lib/droonga/client/connection/droonga-protocol/thread.rb Modified: lib/droonga/client/connection/droonga-protocol/coolio.rb (+1 -0) =================================================================== --- lib/droonga/client/connection/droonga-protocol/coolio.rb 2014-04-30 10:02:03 +0900 (ef435ce) +++ lib/droonga/client/connection/droonga-protocol/coolio.rb 2014-05-02 15:35:09 +0900 (d3673a9) @@ -179,6 +179,7 @@ module Droonga def subscribe(message, options={}, &block) id = message["id"] || generate_id message = message.merge("id" => id, + "replyTo" => @receiver.droonga_name, "from" => @receiver.droonga_name) send(message, options) Modified: lib/droonga/client/connection/droonga-protocol/thread.rb (+3 -1) =================================================================== --- lib/droonga/client/connection/droonga-protocol/thread.rb 2014-04-30 10:02:03 +0900 (a6ffaa8) +++ lib/droonga/client/connection/droonga-protocol/thread.rb 2014-05-02 15:35:09 +0900 (8aba7b9) @@ -72,8 +72,10 @@ module Droonga def subscribe(message, options={}, &block) receiver = create_receiver + receive_end_point = "#{receiver.host}:#{receiver.port}/droonga" message = message.dup - message["from"] = "#{receiver.host}:#{receiver.port}/droonga" + message["replyTo"] = receive_end_point + message["from"] = receive_end_point send(message, options) receive_options = { -------------- next part -------------- HTML����������������������������...下載
