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
# implements the root actor
class Root < AbstractContext
def initialize
# noinspection RubyArgCount
@dead_letter_router = Core.new(parent: reference,
class: DefaultDeadLetterHandler,
supervise: true,
name: :default_dead_letter_handler).reference
end
# to allow spawning of new actors, spawn needs to be called inside the parent Actor
def on_message(message)
case
when message.is_a?(::Array) && message.first == :spawn
Actor.spawn message[1], &message[2]
when message == :dead_letter_routing
@dead_letter_router
else
# ignore
end
end
def dead_letter_routing
@dead_letter_router
end
def behaviour_definition
[*Behaviour.base(:just_log),
*Behaviour.supervising,
*Behaviour.user_messages]
end
end
end
end
|
