Fix Inbox Starvation (#51)

* Fix inbox starvation by continuous delaying next message handling
skrasekmichael · May 6, 2024 · 250a266 · 250a266
1 parent dcccfe9
commit 250a266
Show file tree

Hide file tree

Showing 6 changed files with 441 additions and 5 deletions.
diff --git a/src/TeamUp.Infrastructure/Core/IntegrationEventManager.cs b/src/TeamUp.Infrastructure/Core/IntegrationEventManager.cs
@@ -31,7 +31,8 @@ public void AddIntegrationEvent<TEvent>(TEvent integrationEvent)
 			Id = Guid.NewGuid(),
 			CreatedUtc = _dateTimeProvider.UtcNow,
 			Type = integrationEvent.GetType().FullName!,
-			Data = JsonSerializer.Serialize(integrationEvent, JsonSerializerOptions)
+			Data = JsonSerializer.Serialize(integrationEvent, JsonSerializerOptions),
+			NextProcessingUtc = _dateTimeProvider.UtcNow,
 		};
 
 		_dbContext.Set<OutboxMessage>().Add(message);

diff --git a/src/TeamUp.Infrastructure/Persistence/Migrations/20240506211227_InboxStarvation.Designer.cs b/src/TeamUp.Infrastructure/Persistence/Migrations/20240506211227_InboxStarvation.Designer.cs