diff --git a/Directory.Packages.props b/Directory.Packages.props
index 8b3f9d56..7155a522 100644
--- a/Directory.Packages.props
+++ b/Directory.Packages.props
@@ -21,7 +21,7 @@
     <PackageVersion Include="Azure.Identity" Version="1.21.0" />
     <PackageVersion Include="Microsoft.Azure.Cosmos" Version="3.62.0" />
     <PackageVersion Include="Azure.Messaging.ServiceBus" Version="7.20.2" />
-    <PackageVersion Include="Azure.Storage.Queues" Version="12.23.0" />
+    <PackageVersion Include="Azure.Storage.Queues" Version="12.27.1" />
     <PackageVersion Include="Confluent.Kafka" Version="2.15.0" />
     <PackageVersion Include="Dapr.Client" Version="1.18.5" />
     <PackageVersion Include="FluentValidation" Version="12.1.1" />
diff --git a/src/NetEvolve.Pulse.AzureQueueStorage/Outbox/AzureQueueStorageMessageTransport.cs b/src/NetEvolve.Pulse.AzureQueueStorage/Outbox/AzureQueueStorageMessageTransport.cs
index 319a091f..d3e8ef03 100644
--- a/src/NetEvolve.Pulse.AzureQueueStorage/Outbox/AzureQueueStorageMessageTransport.cs
+++ b/src/NetEvolve.Pulse.AzureQueueStorage/Outbox/AzureQueueStorageMessageTransport.cs
@@ -133,16 +133,18 @@ private async Task<QueueClient> GetQueueClientAsync(CancellationToken cancellati
                 return _queueClient;
             }
 
+            var clientOptions = new QueueClientOptions(QueueClientOptions.ServiceVersion.V2025_11_05);
+
             QueueClient client;
 
             if (!string.IsNullOrWhiteSpace(_options.ConnectionString))
             {
-                client = new QueueClient(_options.ConnectionString, _options.QueueName);
+                client = new QueueClient(_options.ConnectionString, _options.QueueName, clientOptions);
             }
             else
             {
                 var queueUri = new Uri(_options.QueueServiceUri!, _options.QueueName);
-                client = new QueueClient(queueUri, new DefaultAzureCredential());
+                client = new QueueClient(queueUri, new DefaultAzureCredential(), clientOptions);
             }
 
             if (_options.CreateQueueIfNotExists)
diff --git a/tests/NetEvolve.Pulse.Tests.Integration/AzureQueueStorage/AzureQueueStorageMessageTransportIntegrationTests.cs b/tests/NetEvolve.Pulse.Tests.Integration/AzureQueueStorage/AzureQueueStorageMessageTransportIntegrationTests.cs
index 73482262..6c498f41 100644
--- a/tests/NetEvolve.Pulse.Tests.Integration/AzureQueueStorage/AzureQueueStorageMessageTransportIntegrationTests.cs
+++ b/tests/NetEvolve.Pulse.Tests.Integration/AzureQueueStorage/AzureQueueStorageMessageTransportIntegrationTests.cs
@@ -40,7 +40,7 @@ public async Task SendAsync_Creates_queue_and_sends_base64_encoded_message(Cance
 
         await transport.SendAsync(message, cancellationToken).ConfigureAwait(false);
 
-        var queueClient = new QueueClient(containerFixture.ConnectionString, queueName);
+        var queueClient = new QueueClient(containerFixture.ConnectionString, queueName, VerificationClientOptions);
         var response = await queueClient
             .ReceiveMessageAsync(cancellationToken: cancellationToken)
             .ConfigureAwait(false);
@@ -91,7 +91,7 @@ public async Task SendBatchAsync_Sends_all_messages_sequentially(CancellationTok
 
         await transport.SendBatchAsync(messages, cancellationToken).ConfigureAwait(false);
 
-        var queueClient = new QueueClient(containerFixture.ConnectionString, queueName);
+        var queueClient = new QueueClient(containerFixture.ConnectionString, queueName, VerificationClientOptions);
         var response = await queueClient
             .ReceiveMessagesAsync(maxMessages: messageCount, cancellationToken: cancellationToken)
             .ConfigureAwait(false);
@@ -118,7 +118,7 @@ CancellationToken cancellationToken
 
             await transport.SendAsync(message, cancellationToken).ConfigureAwait(false);
 
-            var queueClient = new QueueClient(containerFixture.ConnectionString, queueName);
+            var queueClient = new QueueClient(containerFixture.ConnectionString, queueName, VerificationClientOptions);
             var response = await queueClient
                 .ReceiveMessageAsync(cancellationToken: cancellationToken)
                 .ConfigureAwait(false);
@@ -127,6 +127,10 @@ CancellationToken cancellationToken
         }
     }
 
+    private static readonly QueueClientOptions VerificationClientOptions = new(
+        QueueClientOptions.ServiceVersion.V2025_11_05
+    );
+
     private static string CreateUniqueQueueName() => $"pulse-it-{Guid.NewGuid():N}";
 
     private static OutboxMessage CreateOutboxMessage() =>
diff --git a/tests/NetEvolve.Pulse.Tests.Integration/AzureQueueStorage/AzuriteContainerFixture.cs b/tests/NetEvolve.Pulse.Tests.Integration/AzureQueueStorage/AzuriteContainerFixture.cs
index 11337a78..949d3876 100644
--- a/tests/NetEvolve.Pulse.Tests.Integration/AzureQueueStorage/AzuriteContainerFixture.cs
+++ b/tests/NetEvolve.Pulse.Tests.Integration/AzureQueueStorage/AzuriteContainerFixture.cs
@@ -1,4 +1,4 @@
-namespace NetEvolve.Pulse.Tests.Integration.AzureQueueStorage;
+namespace NetEvolve.Pulse.Tests.Integration.AzureQueueStorage;
 
 using Microsoft.Extensions.Logging.Abstractions;
 using Testcontainers.Azurite;
@@ -9,7 +9,9 @@ namespace NetEvolve.Pulse.Tests.Integration.AzureQueueStorage;
 /// </summary>
 public sealed class AzuriteContainerFixture : IAsyncDisposable, IAsyncInitializer
 {
-    private readonly AzuriteContainer _container = new AzuriteBuilder("mcr.microsoft.com/azure-storage/azurite:3.36.0")
+    private readonly AzuriteContainer _container = new AzuriteBuilder( /*dockerimage*/
+        "mcr.microsoft.com/azure-storage/azurite:3.36.0"
+    )
         .WithLogger(NullLogger.Instance)
         .Build();
 
diff --git a/tests/NetEvolve.Pulse.Tests.Integration/Internals/Services/MongoDbContainerFixture.cs b/tests/NetEvolve.Pulse.Tests.Integration/Internals/Services/MongoDbContainerFixture.cs
index e0418758..a791f080 100644
--- a/tests/NetEvolve.Pulse.Tests.Integration/Internals/Services/MongoDbContainerFixture.cs
+++ b/tests/NetEvolve.Pulse.Tests.Integration/Internals/Services/MongoDbContainerFixture.cs
@@ -6,7 +6,9 @@
 
 public sealed class MongoDbContainerFixture : IAsyncDisposable, IAsyncInitializer
 {
-    private readonly MongoDbContainer _container = new MongoDbBuilder("mongo:8.0")
+    private readonly MongoDbContainer _container = new MongoDbBuilder( /*dockerimage*/
+        "mongo:8.0"
+    )
         .WithLogger(NullLogger.Instance)
         .Build();