From 817ebc8a410c81688d76c2af69734e9560d0d5c5 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Wed, 22 Jan 2025 15:22:22 -0600 Subject: [PATCH 1/2] Make `Resequencer` child of the `AsyncWriteJournal` --- src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs b/src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs index 24028d90962..4a00b7086de 100644 --- a/src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs +++ b/src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs @@ -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"); } /// From a8fbd74aa63b195c096f9e29e234f58b9d218d3c Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Wed, 22 Jan 2025 15:29:22 -0600 Subject: [PATCH 2/2] fix comment --- src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs b/src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs index 4a00b7086de..55b09aefd1e 100644 --- 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;