Merge pull request #71 from wemogy/main

Release
wemogy · Dec 12, 2023 · d45ab58 · d45ab58
2 parents 9949260 + 39d0b58
commit d45ab58
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/...gy.CQRS.Extensions.AzureServiceBus/Processors/AzureServiceBusCommandSessionProcessor`1.cs b/...gy.CQRS.Extensions.AzureServiceBus/Processors/AzureServiceBusCommandSessionProcessor`1.cs
@@ -105,8 +105,17 @@ public async Task HandleMessageAsync(ProcessSessionMessageEventArgs arg)
                         {
                             await Task.Delay(_renewSessionLockInterval, renewSessionLockCancellationToken);
                             Console.WriteLine($"Renewing session lock for session{arg.SessionId}...");
-                            await arg.RenewSessionLockAsync(arg.CancellationToken);
-                            Console.WriteLine($"Renewed session lock for session {arg.SessionId}");
+                            try
+                            {
+                                await arg.RenewSessionLockAsync(renewSessionLockCancellationToken);
+                                Console.WriteLine($"Renewed session lock for session {arg.SessionId}");
+                            }
+                            catch (Exception e)
+                            {
+                                Console.WriteLine($"Failed to renew session lock for session {arg.SessionId}");
+                                Console.WriteLine(e);
+                                throw;
+                            }
                         }
                     },
                     renewSessionLockCancellationTokenSource.Token);