Resequencer should always be a child of the journal actor (#7481)

* Make `Resequencer` child of the `AsyncWriteJournal` * fix comment
akkadotnet · Jan 22, 2025 · 84b767a · 84b767a
1 parent 759e93f
commit 84b767a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs b/src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs
@@ -47,7 +47,7 @@ protected AsyncWriteJournal()
             var extension = Persistence.Instance.Apply(Context.System);
             if (extension == null)
             {
-                throw new ArgumentException("Couldn't initialize SyncWriteJournal instance, because associated Persistence extension has not been used in current actor system context.");
+                throw new ArgumentException("Couldn't initialize AsyncWriteJournal instance, because associated Persistence extension has not been used in current actor system context.");
             }
 
             CanPublish = extension.Settings.Internal.PublishPluginCommands;
@@ -81,7 +81,7 @@ protected AsyncWriteJournal()
             _replayFilterMaxOldWriters = config.GetInt("replay-filter.max-old-writers", 0);
             _replayDebugEnabled = config.GetBoolean("replay-filter.debug", false);
 
-            _resequencer = Context.System.ActorOf(Props.Create(() => new Resequencer()));
+            _resequencer = Context.ActorOf(Props.Create(() => new Resequencer()), "resequencer");
         }
 
         /// <inheritdoc/>