lib/openwfe/participants/participant_map.rb
#
# Dispatches to the given participant (participant name (string) or
# The workitem will be fed to the consume() method of that participant.
# If it's a cancelitem and the participant has a cancel() method,
# it will get called instead.
#
Dispatches to the given participant (participant name (string) or
The workitem will be fed to the consume() method of that participant.
If it's a cancelitem and the participant has a cancel() method,
it will get called instead.
Dispatches to the given participant ( participant name ( string ) or The workitem will be fed to the consume () method of that participant . If it ' s a cancelitem and the participant has a cancel () method it will get called instead .
def dispatch (participant, participant_name, workitem)
      participant ||= lookup_participant(participant_name)
      raise "pmap : no participant named '#{participant_name}'" \
        unless participant
      workitem.participant_name = participant_name
      if participant.respond_to?(:do_not_thread) and participant.do_not_thread
        do_dispatch(participant, workitem)
      else
        Thread.new { do_dispatch(participant, workitem) }
      end
    end
def dispatch ( participant , participant_name , workitem ) participant ||= lookup_participant ( participant_name ) raise "pmap : no participant named '#{participant_name}'" unless participant workitem . participant_name = participant_name if participant . respond_to? ( :do_not_thread ) and participant . do_not_thread do_dispatch ( participant , workitem ) else Thread . new { do_dispatch ( participant , workitem ) } end end
Dispatches to the given participant (participant name (string) or
The workitem will be fed to the consume() method of that participant.
Dispatches to the given participant ( participant name ( string ) or The workitem will be fed to the consume () method of that participant .
# participant may be null (AliasParticipant)
participant
<not_specific>
participant_name
<not_specific>
workitem
<not_specific>