[Streams] Fix ShellRegistered message deadletter log (#7376)

akkadotnet · Nov 1, 2024 · 699aff2 · 699aff2
1 parent 3700809
commit 699aff2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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()