From a6957c272ccdfb60bdbbc3366ae892876cdb733d Mon Sep 17 00:00:00 2001 From: meysamhadeli Date: Sun, 29 Jan 2023 22:47:15 +0330 Subject: [PATCH] Update PersistMessageProcessor --- .../PersistMessageProcessor/PersistMessageProcessor.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/BuildingBlocks/PersistMessageProcessor/PersistMessageProcessor.cs b/src/BuildingBlocks/PersistMessageProcessor/PersistMessageProcessor.cs index ce2c8eb..674a438 100644 --- a/src/BuildingBlocks/PersistMessageProcessor/PersistMessageProcessor.cs +++ b/src/BuildingBlocks/PersistMessageProcessor/PersistMessageProcessor.cs @@ -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 logger,