1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
module Concurrent
module Actor
module Behaviour
# Collects returning value and sets the ResolvableFuture in the {Envelope} or error on failure.
class SetResults < Abstract
attr_reader :error_strategy
def initialize(core, subsequent, core_options, error_strategy)
super core, subsequent, core_options
@error_strategy = Match! error_strategy, :just_log, :terminate!, :pause!
end
def on_envelope(envelope)
result = pass envelope
if result != MESSAGE_PROCESSED && !envelope.future.nil?
envelope.future.fulfill result
log(DEBUG) { "finished processing of #{envelope.message.inspect}"}
end
nil
rescue => error
log ERROR, error
case error_strategy
when :terminate!
terminate!
when :pause!
behaviour!(Pausing).pause!(error)
when :just_log
# nothing
else
raise
end
envelope.future.reject error unless envelope.future.nil?
end
end
end
end
end
|
