Class: Ruote::LostReplyParticipant

Inherits:
Participant show all
Defined in:
lib/ruote/part/test_participants.rb

Overview

This participant removes itself (well, the corresponding participant expression) and never replies.

Used to simulate lost replies.

Instance Attribute Summary

Attributes included from LocalParticipant

#context, #error, #fei, #flavour, #msg, #workitem

Instance Method Summary collapse

Methods inherited from Participant

#on_cancel

Methods included from LocalParticipant

#_accept?, #_dont_thread?, #_on_cancel, #_on_reply, #_on_workitem, #_rtimeout, #applied_workitem, #fexp, #is_cancelled?, #is_gone?, #lookup_variable, #participant_name, #re_dispatch, #reply_to_engine, #unschedule_re_dispatch

Methods included from ReceiverMixin

#fetch_flow_expression, #fetch_workitem, #flunk, #launch, #receive, #reply, #sign

Instance Method Details

#do_not_threadObject


77
# File 'lib/ruote/part/test_participants.rb', line 77

def do_not_thread; true; end

#on_workitemObject


69
70
71
72
73
74
75
# File 'lib/ruote/part/test_participants.rb', line 69

def on_workitem

  r = context.storage.delete(fexp.h)
  raise "failed to remove self" if r != nil

  # do not reply.
end