diff --git a/src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs b/src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs index 2bf0fc6..c74dee3 100644 --- a/src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs +++ b/src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs @@ -75,11 +75,13 @@ public async Task Consume(ConsumeContext context) logger.LogError(ex, "Exception thrown while consuming message {messageId} by {consumerId}", messageId, _consumerId); - + await transactionScope.RollbackAsync(); - inboxMessage.UpdatedAt = DateTime.UtcNow; - await dbContext.SaveChangesAsync(); + await dbContext.InboxMessages + .Where(x => x.MessageId == messageId && x.ConsumerId == _consumerId) + .ExecuteUpdateAsync(x => x.SetProperty(x => x.UpdatedAt, x => DateTime.UtcNow)); + throw; } } diff --git a/src/MassTransit.PostgresOutbox/MassTransit.PostgresOutbox.csproj b/src/MassTransit.PostgresOutbox/MassTransit.PostgresOutbox.csproj index c5d51ab..6e0d895 100644 --- a/src/MassTransit.PostgresOutbox/MassTransit.PostgresOutbox.csproj +++ b/src/MassTransit.PostgresOutbox/MassTransit.PostgresOutbox.csproj @@ -8,7 +8,7 @@ Readme.md Pandatech MIT - 3.0.2 + 3.0.3 Pandatech.MassTransit.PostgresOutbox Pandatech MassTransit PostgreSQL Outbox Extension Pandatech, library, postgres, distributed systems, microservices, modular monolith, messaging, efcore, mass transit, outbox pattern, inbox pattern