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

Merge pull request #115 from meysamhadeli/develop

Browse Source 
Develop
This commit is contained in:
Meysam Hadeli 2023-01-22 03:45:53 +03:30 committed by GitHub
commit 535d0edee4
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;
using Exception = System.Exception;
public class PersistMessageProcessor : IPersistMessageProcessor
{
private readonly ILogger<PersistMessageProcessor> _logger;
@ -56,7 +54,7 @@ public class PersistMessageProcessor : IPersistMessageProcessor
public async Task<IReadOnlyList<PersistMessage>> GetByFilterAsync(Expression<Func<PersistMessage, bool>> predicate,
CancellationToken cancellationToken = default)
{
return (await _persistMessageDbContext.PersistMessages.Where(predicate).ToListAsync(cancellationToken))
return (await _persistMessageDbContext.PersistMessages.AsNoTracking().Where(predicate).ToListAsync(cancellationToken))
.AsReadOnly();
}
@ -112,7 +110,7 @@ public class PersistMessageProcessor : IPersistMessageProcessor
public async Task ProcessAllAsync(CancellationToken cancellationToken = default)
{
var messages = await _persistMessageDbContext.PersistMessages
var messages = await _persistMessageDbContext.PersistMessages.AsNoTracking()
.Where(x => x.MessageStatus != MessageStatus.Processed)
.ToListAsync(cancellationToken);