Update PersistMessageProcessor

This commit is contained in:
meysamhadeli 2023-01-29 22:47:15 +03:30
parent 196f0a0a17
commit a6957c272c

View File

@ -18,7 +18,7 @@ public class PersistMessageProcessor : IPersistMessageProcessor
private readonly IMediator _mediator;
private readonly IPersistMessageDbContext _persistMessageDbContext;
private readonly IPublishEndpoint _publishEndpoint;
private static SemaphoreSlim Semaphore => new SemaphoreSlim(initialCount: 0, maxCount: 1);
private SemaphoreSlim Semaphore => new SemaphoreSlim(1);
public PersistMessageProcessor(
ILogger<PersistMessageProcessor> logger,