lib/openwfe/expressions/fe_participant.rb in openwferu-0.9.6 vs lib/openwfe/expressions/fe_participant.rb in openwferu-0.9.7

- old
+ new

@@ -58,10 +58,12 @@ # tied to the engine. # class ParticipantExpression < FlowExpression include TimeoutMixin + names :participant + attr_accessor \ :participant_name, :applied_workitem # @@ -86,9 +88,14 @@ get_participant_map.dispatch(@participant_name, workitem) end #def reply (workitem) #end + + def reply_to_parent (workitem) + unschedule_timeout() + super(workitem) + end # # The cancel() method of a ParticipantExpression is particular : it # will emit a CancelItem instance towards the participant itself # to notify it of the cancellation.