t.rb

class MyDispatchWorker < Ruote::Worker
  def initialize(name, storage, allowed_participants)
    super(name, storage)
    @allowed_participants = allowed_participants
  end
  def process(msg)
    return true unless DISP_ACTIONS.include?(msg['action'])
    return true unless @allowed_participants.include?(msg['participant_name'])
    super
  end
end