lib/openwfe/participants/participant_map.rb
#
# The actual dispatch work is here, along with error catching
#
The actual dispatch work is here, along with error catching
The actual dispatch work is here along with error catching
def do_dispatch (participant, workitem)
      return do_cancel(participant, workitem) if workitem.is_a?(CancelItem)
      onotify(:dispatch, :before_consume, workitem)
      workitem.dispatch_time = Time.now
      participant.consume(workitem)
      onotify(:dispatch, :after_consume, workitem)
    rescue Exception => e
      get_expression_pool.handle_error(e, workitem.fei, :apply, workitem)
    end
def do_dispatch ( participant , workitem ) return do_cancel ( participant , workitem ) if workitem . is_a? ( CancelItem ) onotify ( :dispatch , :before_consume , workitem ) workitem . dispatch_time = Time . now participant . consume ( workitem ) onotify ( :dispatch , :after_consume , workitem ) rescue Exception => e get_expression_pool . handle_error ( e , workitem . fei , :apply , workitem ) end
The actual dispatch work is here, along with error catching
The actual dispatch work is here along with error catching
participant
<not_specific>
workitem
<not_specific>