gistfile1.txt

class EngineParticipant
  include Ruote::LocalParticipant
  def initialize (opts)
    @opts = opts
  end
  def consume (wi)
    if wi.fields.has_key? 'command'
      case wi.lookup "command"
      when "register"
        puts "Registering:"
        $engine.register_participant(wi.lookup("name"), RuoteAMQP::Participant, wi.lookup("options"))
      end
    end
    reply_to_engine(workitem)
  end
end
$engine.register_participant 'engine_command', EngineParticipant