File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/MassTransit.PostgresOutbox/Abstractions Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -43,7 +43,7 @@ public async Task Consume(ConsumeContext<TMessage> context)
4343 {
4444 dbContext . InboxMessages . Add ( new InboxMessage
4545 {
46- MessageId = messageId ! . Value ,
46+ MessageId = messageId . Value ,
4747 CreatedAt = DateTime . UtcNow ,
4848 State = MessageState . New ,
4949 ConsumerId = _consumerId ,
@@ -52,7 +52,7 @@ public async Task Consume(ConsumeContext<TMessage> context)
5252 await dbContext . SaveChangesAsync ( ) ;
5353 }
5454
55- using var transactionScope =
55+ await using var transactionScope =
5656 await dbContext . Database . BeginTransactionAsync ( System . Data . IsolationLevel . ReadCommitted ) ;
5757
5858 var inboxMessage = await dbContext . InboxMessages
@@ -79,11 +79,11 @@ public async Task Consume(ConsumeContext<TMessage> context)
7979 }
8080 finally
8181 {
82- inboxMessage ! . UpdatedAt = DateTime . UtcNow ;
82+ inboxMessage . UpdatedAt = DateTime . UtcNow ;
8383 await dbContext . SaveChangesAsync ( ) ;
8484 await transactionScope . CommitAsync ( ) ;
8585 }
8686 }
8787
88- public abstract Task Consume ( TMessage message ) ;
88+ protected abstract Task Consume ( TMessage message ) ;
8989}
You can’t perform that action at this time.
0 commit comments