# File lib/fluent/process.rb, line 264 def initialize(forwarders) @forwarders = forwarders @rr = 1 end
# File lib/fluent/process.rb, line 269 def emit(tag, es) forwarder = @forwarders[@rr] @rr = (@rr + 1) % @forwarders.length forwarder.emit(tag, es) end