Sha256: 0cd2f93cf607c91c1b639d891a3e68706a90259c9c7e24ba7545a86c093ff20f
Contents?: true
Size: 547 Bytes
Versions: 11
Compression:
Stored size: 547 Bytes
Contents
class RFlow module Components class Replicate < Component input_port :in output_port :out output_port :errored def process_message(input_port, input_port_key, connection, message) out.each do |connections| begin connections.send_message message rescue Exception => e RFlow.logger.debug "#{self.class} Message caused exception: #{e.class}: #{e.message}: #{e.backtrace}" errored.send_message message end end end end end end
Version data entries
11 entries across 11 versions & 1 rubygems