We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 01926d9 commit d44e14eCopy full SHA for d44e14e
1 file changed
Core/Cleipnir.ResilientFunctions/CoreRuntime/FlowsManagers.cs
@@ -71,6 +71,7 @@ public Task Push(IReadOnlyList<StoredMessages> messages)
71
// Messages for flow types not (yet) registered on this replica cannot be delivered here. Reopen their
72
// positions so delivery is retried on a later poll - the type may simply not have been registered yet
73
// (start-up ordering or a rolling deployment).
74
+ // todo log a warning here
75
if (unregistered.Count > 0)
76
_messageClearer.ReopenPositions(
77
unregistered.SelectMany(sm => sm.Messages).Select(m => m.Position)
0 commit comments