YUKI Hiroshi
null+****@clear*****
Mon Apr 6 14:42:18 JST 2015
YUKI Hiroshi 2015-04-06 14:42:18 +0900 (Mon, 06 Apr 2015) New Revision: fb7c02bdb3d4c8f757e057779c8141ba734eae3c https://github.com/droonga/droonga-engine/commit/fb7c02bdb3d4c8f757e057779c8141ba734eae3c Message: Register on_forward callback to send buffered packets Modified files: lib/droonga/engine_node.rb Modified: lib/droonga/engine_node.rb (+3 -0) =================================================================== --- lib/droonga/engine_node.rb 2015-04-02 19:34:01 +0900 (9c8b8f8) +++ lib/droonga/engine_node.rb 2015-04-06 14:42:18 +0900 (e433ce6) @@ -31,6 +31,9 @@ module Droonga @sender_node_metadata = params[:metadata] @buffer = ForwardBuffer.new(name) + @buffer.on_forward = lambda do |message, destination| + output(message, destination) + end parsed_name = parse_node_name(@name) @sender = FluentMessageSender.new(loop, -------------- next part -------------- HTML����������������������������...Download