# File lib/ruote/part/dispatch_pool.rb, line 86
    def do_dispatch (participant, msg)

      workitem = Ruote::Workitem.new(msg['workitem'])

      workitem.fields['dispatched_at'] = Ruote.now_to_utc_s

      participant.consume(workitem)

      @context.storage.put_msg('dispatched', 'fei' => msg['fei'])
        # once the consume is done, asynchronously flag the
        # participant expression as 'dispatched'
    end