File tree 1 file changed +4
-4
lines changed
src/MassTransit.PostgresOutbox/Abstractions
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)
43
43
{
44
44
dbContext . InboxMessages . Add ( new InboxMessage
45
45
{
46
- MessageId = messageId ! . Value ,
46
+ MessageId = messageId . Value ,
47
47
CreatedAt = DateTime . UtcNow ,
48
48
State = MessageState . New ,
49
49
ConsumerId = _consumerId ,
@@ -52,7 +52,7 @@ public async Task Consume(ConsumeContext<TMessage> context)
52
52
await dbContext . SaveChangesAsync ( ) ;
53
53
}
54
54
55
- using var transactionScope =
55
+ await using var transactionScope =
56
56
await dbContext . Database . BeginTransactionAsync ( System . Data . IsolationLevel . ReadCommitted ) ;
57
57
58
58
var inboxMessage = await dbContext . InboxMessages
@@ -79,11 +79,11 @@ public async Task Consume(ConsumeContext<TMessage> context)
79
79
}
80
80
finally
81
81
{
82
- inboxMessage ! . UpdatedAt = DateTime . UtcNow ;
82
+ inboxMessage . UpdatedAt = DateTime . UtcNow ;
83
83
await dbContext . SaveChangesAsync ( ) ;
84
84
await transactionScope . CommitAsync ( ) ;
85
85
}
86
86
}
87
87
88
- public abstract Task Consume ( TMessage message ) ;
88
+ protected abstract Task Consume ( TMessage message ) ;
89
89
}
You can’t perform that action at this time.
0 commit comments