elias/booking-microservices
1
0
Fork 0
mirror of https://github.com/meysamhadeli/booking-microservices.git synced 2026-04-30 01:45:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #114 from meysamhadeli/fix/as-no-tracking

Browse Source 
fix: try for fix DbUpdateConcurrencyException
This commit is contained in:
Meysam Hadeli 2023-01-22 03:25:18 +03:30 committed by GitHub
commit e57ec7315c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/BuildingBlocks/PersistMessageProcessor/PersistMessageProcessor.cs
View File

@ -11,8 +11,6 @@ using Microsoft.Extensions.Logging;
namespace BuildingBlocks.PersistMessageProcessor; namespace BuildingBlocks.PersistMessageProcessor;
using Exception = System.Exception;
public class PersistMessageProcessor : IPersistMessageProcessor public class PersistMessageProcessor : IPersistMessageProcessor
{ {
private readonly ILogger<PersistMessageProcessor> _logger; private readonly ILogger<PersistMessageProcessor> _logger;
@ -56,7 +54,7 @@ public class PersistMessageProcessor : IPersistMessageProcessor
public async Task<IReadOnlyList<PersistMessage>> GetByFilterAsync(Expression<Func<PersistMessage, bool>> predicate, public async Task<IReadOnlyList<PersistMessage>> GetByFilterAsync(Expression<Func<PersistMessage, bool>> predicate,
CancellationToken cancellationToken = default) CancellationToken cancellationToken = default)
{ {
return (await _persistMessageDbContext.PersistMessages.Where(predicate).ToListAsync(cancellationToken)) return (await _persistMessageDbContext.PersistMessages.AsNoTracking().Where(predicate).ToListAsync(cancellationToken))
.AsReadOnly(); .AsReadOnly();
} }
@ -112,7 +110,7 @@ public class PersistMessageProcessor : IPersistMessageProcessor
public async Task ProcessAllAsync(CancellationToken cancellationToken = default) public async Task ProcessAllAsync(CancellationToken cancellationToken = default)
{ {
var messages = await _persistMessageDbContext.PersistMessages var messages = await _persistMessageDbContext.PersistMessages.AsNoTracking()
.Where(x => x.MessageStatus != MessageStatus.Processed) .Where(x => x.MessageStatus != MessageStatus.Processed)
.ToListAsync(cancellationToken); .ToListAsync(cancellationToken);