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

Version Path
rflow-1.3.0 lib/rflow/components/replicate.rb
rflow-1.3.0a1 lib/rflow/components/replicate.rb
rflow-1.2.0 lib/rflow/components/replicate.rb
rflow-1.1.0 lib/rflow/components/replicate.rb
rflow-1.0.1 lib/rflow/components/replicate.rb
rflow-1.0.0 lib/rflow/components/replicate.rb
rflow-1.0.0a6 lib/rflow/components/replicate.rb
rflow-1.0.0a5 lib/rflow/components/replicate.rb
rflow-1.0.0a4 lib/rflow/components/replicate.rb
rflow-1.0.0a3 lib/rflow/components/replicate.rb
rflow-1.0.0a2 lib/rflow/components/replicate.rb