RuoteAMQP error handling example

process.rb

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"

       # This participant will only be called if 'completed' is false or nil
       human_participant :activity => "AMQP error: ${f:error}"

     end
  end
end