Changed renew session lock cancellation token and log exception

wemogy · Dec 12, 2023 · ebf35df · ebf35df
1 parent afe2467
commit ebf35df
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);