updated the the lock and rabbit queue expirary

dbones-labs · Sep 12, 2021 · c8dc42c · c8dc42c
1 parent 0a9f64a
commit c8dc42c
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 4 deletions.
diff --git a/src/Eventual.RabbitMq/Configuration/RabbitMqBusConfiguration.cs b/src/Eventual.RabbitMq/Configuration/RabbitMqBusConfiguration.cs
@@ -44,7 +44,7 @@ public class RabbitMqBusConfiguration : BusConfiguration
         /// <summary>
         /// how long a queue should stay before it is removed for inactivity
         /// </summary>
-        public long ExpireQueueAfter { get; set; } = 3600000; //1 hour
+        public long ExpireQueueAfter { get; set; } = 28800000; //8 hours //3600000; //1 hour
 
 
         /// <summary>

diff --git a/src/Eventual.RabbitMq/Eventual.RabbitMq.csproj b/src/Eventual.RabbitMq/Eventual.RabbitMq.csproj
@@ -9,7 +9,7 @@
   </PropertyGroup>
 
   <PropertyGroup>
-    <Version>0.0.3</Version>
+    <Version>0.0.5</Version>
   </PropertyGroup>
 
   <PropertyGroup>

diff --git a/src/Eventual/Eventual.csproj b/src/Eventual/Eventual.csproj
@@ -9,7 +9,7 @@
   </PropertyGroup>
 
   <PropertyGroup>
-    <Version>0.0.4</Version>
+    <Version>0.0.5</Version>
   </PropertyGroup>
 
   <PropertyGroup>

diff --git a/src/Eventual/Infrastructure/Lock.cs b/src/Eventual/Infrastructure/Lock.cs
@@ -5,7 +5,7 @@
 
     public class Lock
     {
-        private readonly ReaderWriterLockSlim _internalLock = new ReaderWriterLockSlim();
+        private readonly ReaderWriterLockSlim _internalLock = new();
 
         public void GetInsert(Func<bool> read, Action update)
         {
@@ -16,6 +16,8 @@ public void GetInsert(Func<bool> read, Action update)
                 _internalLock.EnterWriteLock();
                 try
                 {
+                    //do another check to be sure.
+                    if (read()) return;
                     update();
                 }
                 finally