Contents

module MiniCamel
  module Processor
    class Pipeline < Base

      values do
        attribute :routes, [Symbol]
      end

      def call(exchange)
        routes.each do |route|
          env.call_route(route, exchange)
        end
      end

    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
mini_camel-0.5.8	lib/mini_camel/processor/pipeline.rb