Merge pull request #395 from hangfire-postgres/features/386-change-lock-exception-type

Changed distributed lock exception type

Author: azygis

src/Hangfire.PostgreSql/PostgreSqlDistributedLock.cs

@@ -91,7 +91,7 @@ internal static void Release(IDbConnection connection, string resource, PostgreS
 
       if (!LockHandler.TryRemoveLock(resource, connection, options, false))
       {
-        throw new PostgreSqlDistributedLockException($"Could not release a lock on the resource '{resource}'. Lock does not exist.");
+        throw new PostgreSqlDistributedLockException(resource);
       }
     }
 
@@ -102,14 +102,12 @@ public static void Lock(string resource, TimeSpan timeout, IDbConnection connect
         Stopwatch lockAcquiringTime = Stopwatch.StartNew();
 
         bool tryAcquireLock = true;
-        Exception lastException = null;
         Func<IDbConnection, string, string, bool> tryLock = options.UseNativeDatabaseTransactions
           ? TransactionLockHandler.TryLock
           : UpdateCountLockHandler.TryLock;
 
         while (tryAcquireLock)
         {
-          lastException = null;
           if (connection.State != ConnectionState.Open)
           {
             connection.Open();
@@ -126,7 +124,6 @@ public static void Lock(string resource, TimeSpan timeout, IDbConnection connect
           }
           catch (Exception ex)
           {
-            lastException = ex;
             Log(resource, "Failed to acquire lock", ex);
           }
 
@@ -153,7 +150,7 @@ public static void Lock(string resource, TimeSpan timeout, IDbConnection connect
           }
         }
 
-        throw new PostgreSqlDistributedLockException($@"Could not place a lock on the resource '{resource}': Lock timeout.", lastException);
+        throw new PostgreSqlDistributedLockException(resource);
       }
 
       public static bool TryRemoveLock(string resource, IDbConnection connection, PostgreSqlStorageOptions options, bool onlyExpired)

src/Hangfire.PostgreSql/PostgreSqlDistributedLockException.cs

@@ -20,17 +20,14 @@
 //    Special thanks goes to him.
 
 using System;
+using Hangfire.Storage;
 
 namespace Hangfire.PostgreSql
 {
   [Serializable]
-  public class PostgreSqlDistributedLockException : Exception
+  public class PostgreSqlDistributedLockException : DistributedLockTimeoutException
   {
-    public PostgreSqlDistributedLockException(string message) : base(message)
-    {
-    }
-
-    public PostgreSqlDistributedLockException(string message, Exception innerException) : base(message, innerException)
+    public PostgreSqlDistributedLockException(string resource) : base(resource)
     {
     }
   }