Skip to content

Commit 96cea54

Browse files
committed
allow to retrieve default dead_letter_routing instance from Root
1 parent ae0bf3b commit 96cea54

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

lib/concurrent/actor/root.rb

+4-1
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,11 @@ def initialize
1313

1414
# to allow spawning of new actors, spawn needs to be called inside the parent Actor
1515
def on_message(message)
16-
if message.is_a?(Array) && message.first == :spawn
16+
case
17+
when message.is_a?(Array) && message.first == :spawn
1718
Actor.spawn message[1], &message[2]
19+
when message == :dead_letter_routing
20+
@dead_letter_router
1821
else
1922
# ignore
2023
end

0 commit comments

Comments
 (0)