Skip to content

Commit 84b767a

Browse files
Resequencer should always be a child of the journal actor (#7481)
* Make `Resequencer` child of the `AsyncWriteJournal` * fix comment
1 parent 759e93f commit 84b767a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/core/Akka.Persistence/Journal/AsyncWriteJournal.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ protected AsyncWriteJournal()
4747
var extension = Persistence.Instance.Apply(Context.System);
4848
if (extension == null)
4949
{
50-
throw new ArgumentException("Couldn't initialize SyncWriteJournal instance, because associated Persistence extension has not been used in current actor system context.");
50+
throw new ArgumentException("Couldn't initialize AsyncWriteJournal instance, because associated Persistence extension has not been used in current actor system context.");
5151
}
5252

5353
CanPublish = extension.Settings.Internal.PublishPluginCommands;
@@ -81,7 +81,7 @@ protected AsyncWriteJournal()
8181
_replayFilterMaxOldWriters = config.GetInt("replay-filter.max-old-writers", 0);
8282
_replayDebugEnabled = config.GetBoolean("replay-filter.debug", false);
8383

84-
_resequencer = Context.System.ActorOf(Props.Create(() => new Resequencer()));
84+
_resequencer = Context.ActorOf(Props.Create(() => new Resequencer()), "resequencer");
8585
}
8686

8787
/// <inheritdoc/>

0 commit comments

Comments
 (0)