From 699aff2e4c0655054989dc1c3b87bf7822ba12d5 Mon Sep 17 00:00:00 2001 From: Gregorius Soedharmo Date: Sat, 2 Nov 2024 00:26:12 +0700 Subject: [PATCH] [Streams] Fix ShellRegistered message deadletter log (#7376) --- .../Implementation/Fusing/ActorGraphInterpreter.cs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/core/Akka.Streams/Implementation/Fusing/ActorGraphInterpreter.cs b/src/core/Akka.Streams/Implementation/Fusing/ActorGraphInterpreter.cs index c97c51cb558..5b6c72aaf55 100644 --- a/src/core/Akka.Streams/Implementation/Fusing/ActorGraphInterpreter.cs +++ b/src/core/Akka.Streams/Implementation/Fusing/ActorGraphInterpreter.cs @@ -767,7 +767,9 @@ public AsyncInput(GraphInterpreterShell shell, GraphStageLogic logic, object @ev public GraphInterpreterShell Shell { get; } } - private class ShellRegistered + // This is the Resume internal API message in JVM, it is used to prevent/short circuit recursive calls + // inside a stream. Harmless when dead-lettered. + private class ShellRegistered: IDeadLetterSuppression { public static readonly ShellRegistered Instance = new(); private ShellRegistered()