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.