Register on_forward callback to send buffered packets

droonga · Apr 6, 2015 · fb7c02b · fb7c02b
1 parent 3cd36b6
commit fb7c02b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/droonga/engine_node.rb b/lib/droonga/engine_node.rb
@@ -31,6 +31,9 @@ def initialize(name, state, loop, params)
       @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,