droonga/fluent-plugin-droonga at f5229c2 [master] dispatcher: use "message" instead of "envelope" (Groonga-commit) - Groonga - fulltext search engine.

Kouhei Sutou	2013-12-20 17:58:43 +0900 (Fri, 20 Dec 2013)

  New Revision: f5229c2dab421c3b196ad182f4c6ead9bc336107
  https://github.com/droonga/fluent-plugin-droonga/commit/f5229c2dab421c3b196ad182f4c6ead9bc336107

  Message:
    dispatcher: use "message" instead of "envelope"

  Modified files:
    lib/droonga/dispatcher.rb

  Modified: lib/droonga/dispatcher.rb (+10 -10)
===================================================================

--- lib/droonga/dispatcher.rb    2013-12-20 17:56:35 +0900 (18674c8)
+++ lib/droonga/dispatcher.rb    2013-12-20 17:58:43 +0900 (6eb5bbf)
@@ -25,7 +25,7 @@ require "droonga/farm"
 
 module Droonga
   class Dispatcher
-    attr_reader :name, :envelope
+    attr_reader :name
 
     def initialize(options)
       @options = options
@@ -61,12 +61,12 @@ module Droonga
       @loop_thread.join
     end
 
-    def handle_message(envelope)
-      @envelope = envelope
-      if envelope["type"] == "dispatcher"
-        process_internal_message(envelope["body"])
+    def handle_message(message)
+      @message = message
+      if message["type"] == "dispatcher"
+        process_internal_message(message["body"])
       else
-        process_input_message(envelope)
+        process_input_message(message)
       end
     end
 
@@ -77,7 +77,7 @@ module Droonga
     end
 
     def reply(body)
-      adapted_message = @output_adapter.adapt(@envelope.merge("body" => body))
+      adapted_message = @output_adapter.adapt(@message.merge("body" => body))
       @forwarder.forward(adapted_message,
                          adapted_message["replyTo"])
     end
@@ -105,7 +105,7 @@ module Droonga
       if local?(destination)
         process_internal_message(message)
       else
-        @forwarder.forward(envelope.merge("body" => message),
+        @forwarder.forward(@message.merge("body" => message),
                            "type" => "dispatcher",
                            "to"   => farm_path(destination))
       end
@@ -114,8 +114,8 @@ module Droonga
     # TODO: Use more meaningful name
     def process_in_farm(route, message, type, synchronous)
       # TODO: validate route is farm path
-      envelope =****@envel*****("body" => message, "type" => type)
-      @farm.process(route, envelope, synchronous)
+      message =****@messa*****("body" => message, "type" => type)
+      @farm.process(route, message, synchronous)
     end
 
     def generate_id
-------------- next part --------------
HTML����������������������������...
Download 


Groonga - fulltext search engine.

[Groonga-commit] droonga/fluent-plugin-droonga at f5229c2 [master] dispatcher: use "message" instead of "envelope"