fix

Author: krlisecovadis

src/Ev.ServiceBus/Reception/Extensions/MessageContextExtensions.cs

@@ -33,15 +33,15 @@ private static async Task SendToSourceAsync(this MessageContext messageContext,
             case ClientType.Queue:
             {
                 // For queues, ResourceId is directly the queue name
-                var sender = client.CreateSender(messageContext.ResourceId);
+                await using var sender = client.CreateSender(messageContext.ResourceId);
                 await sender.SendMessageAsync(message, cancellationToken);
                 break;
             }
             case ClientType.Subscription:
             {
                 // For subscriptions, ResourceId is in format "topicName/Subscriptions/subscriptionName"
                 var topicName = messageContext.ResourceId.Split('/')[0];
-                var sender = client.CreateSender(topicName);
+                await using var sender = client.CreateSender(topicName);
                 await sender.SendMessageAsync(message, cancellationToken);
                 break;
             }

src/Ev.ServiceBus/Reception/MessageReceptionHandler.cs

@@ -53,15 +53,14 @@ public async Task HandleMessageAsync(MessageContext context)
 
             if (_serviceBusOptions.Settings.UseIsolation)
             {
-                var expectedIsolationKey = _serviceBusOptions.Settings.IsolationKey
-                                           ?? throw new ArgumentNullException(_serviceBusOptions.Settings.IsolationKey);
+                var expectedIsolationKey = _serviceBusOptions.Settings.IsolationKey;
 
                 var receivedIsolationKey = context.IsolationKey
                                            ?? string.Empty;
 
                 if (receivedIsolationKey != expectedIsolationKey)
                 {
-                    await HandleIsolationKeyMismatchAsync(context, expectedIsolationKey, receivedIsolationKey);
+                    await HandleIsolationKeyMismatchAsync(context, expectedIsolationKey!, receivedIsolationKey);
                     return;
                 }
             }
@@ -127,10 +126,9 @@ private async Task HandleIsolationKeyMismatchAsync(MessageContext context, strin
     {
         _logger.IgnoreMessage(expectedKey, receivedKey);
 
-        var connectionSettings = _serviceBusOptions.Settings.ConnectionSettings
-                                 ?? throw new ArgumentNullException(nameof(_serviceBusOptions.Settings.ConnectionSettings));
+        var connectionSettings = _serviceBusOptions.Settings.ConnectionSettings;
 
-        var client = _registry.CreateOrGetServiceBusClient(connectionSettings)
+        var client = _registry.CreateOrGetServiceBusClient(connectionSettings!)
                      ?? throw new InvalidOperationException("Failed to create ServiceBusClient");
 
         await context.CompleteAndResendMessageAsync(