Merge pull request #17 from PandaTechAM/development

Improve exception handling in InboxConsumer

Author: mnacmargaryan

src/MassTransit.PostgresOutbox/Abstractions/InboxConsumer.cs

@@ -75,11 +75,13 @@ public async Task Consume(ConsumeContext<TMessage> 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;
       }
    }

src/MassTransit.PostgresOutbox/MassTransit.PostgresOutbox.csproj

@@ -8,7 +8,7 @@
         <PackageReadmeFile>Readme.md</PackageReadmeFile>
         <Authors>Pandatech</Authors>
         <Copyright>MIT</Copyright>
-        <Version>3.0.2</Version>
+        <Version>3.0.3</Version>
         <PackageId>Pandatech.MassTransit.PostgresOutbox</PackageId>
         <Title>Pandatech MassTransit PostgreSQL Outbox Extension</Title>
         <PackageTags>Pandatech, library, postgres, distributed systems, microservices, modular monolith, messaging, efcore, mass transit, outbox pattern, inbox pattern</PackageTags>