hading

Ruote.process_definition :name => 'Test' do
  sequence do

     # Loop, depending on the amqp participant to set 'completed' once it has successfully processed the
     # workitem.
     _loop :break_if => "${f:completed}" do

       # This remote participant will either set a field called 'completed' to true when it is done,
       # or set 'error' with the exception.
       amqp_participant :activity => "Do something"

hading

# Copyright 2011© MaestroDev.  All rights reserved.

module Maestro
  
  #
  # An error class for error emitted by the "remote side" and received here.
  #
  class ReceiveError < RuntimeError

    attr_reader :fei