Upgrade clients

Signed-off-by: Tomasz Maruszak <maruszaktomasz@gmail.com>

Author: zarusz

src/Infrastructure/docker-compose.yml

@@ -61,7 +61,7 @@ services:
 
   mqtt:
     container_name: slim.mqtt
-    image: eclipse-mosquitto:2.0.18
+    image: eclipse-mosquitto:2.0.22
     ports:
       - "1883:1883" #default mqtt port
       - "9001:9001" #default mqtt port for websockets
@@ -72,7 +72,7 @@ services:
 
   psqldb:
     container_name: slim.psql
-    image: postgres:17.4
+    image: postgres:17.7
     environment:
       - POSTGRES_USER=postgres
       - POSTGRES_PASSWORD=SecretP@55word
@@ -83,7 +83,7 @@ services:
 
   rabbitmq:
     container_name: slim.rabbitmq
-    image: rabbitmq:3.12.14-management-alpine
+    image: rabbitmq:4.2.3-management-alpine
     ports:
       - 5672:5672
       - 15672:15672 # user/pass: guest/guest
@@ -92,15 +92,15 @@ services:
 
   redis:
     container_name: slim.redis
-    image: redis:7.2.5
+    image: redis:8.4
     ports:
       - 6379:6379
     networks:
       - slim
 
   sqldb:
     container_name: slim.sql
-    image: mcr.microsoft.com/mssql/server:2022-CU13-ubuntu-22.04
+    image: mcr.microsoft.com/mssql/server:2022-CU21-ubuntu-22.04
     environment:
       - ACCEPT_EULA=Y
       - SA_PASSWORD=SuperSecretP@55word
@@ -111,7 +111,7 @@ services:
 
   storage:
     container_name: slim.storage
-    image: mcr.microsoft.com/azure-storage/azurite:3.31.0
+    image: mcr.microsoft.com/azure-storage/azurite:3.33.0
     command: "azurite --blobHost 0.0.0.0 --blobPort 11000 --queueHost 0.0.0.0 --queuePort 11001 --tableHost 0.0.0.0 --tablePort 11002 --location /data"
     environment:
       - AZURITE_ACCOUNTS=devstoreaccount1:Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==;
@@ -124,7 +124,7 @@ services:
 
   nats:
     container_name: slim.nats
-    image: nats:2.10
+    image: nats:2.12.4
     ports:
       - 4222:4222
     networks:

src/Tests/SlimMessageBus.Host.Outbox.Sql.DbContext.Test/BaseOutboxIntegrationTest.cs

@@ -36,7 +36,8 @@ protected async Task WaitForOutboxToBeDrained(int timeoutSeconds = 10)
             {
                 var context = scope.ServiceProvider.GetRequiredService<CustomerContext>();
 
-                // Query the Outbox table directly to count pending messages
+                // Query the Outbox table to count pending messages
+                // DeliveryComplete = 0 means the message hasn't been delivered yet
                 var connection = context.Database.GetDbConnection();
                 var wasOpen = connection.State == System.Data.ConnectionState.Open;
                 if (!wasOpen)
@@ -47,7 +48,7 @@ protected async Task WaitForOutboxToBeDrained(int timeoutSeconds = 10)
                 try
                 {
                     using var command = connection.CreateCommand();
-                    command.CommandText = $"SELECT COUNT(*) FROM [{CustomerContext.Schema}].[Outbox] WHERE [DeliveryDateTimeUtc] IS NULL";
+                    command.CommandText = $"SELECT COUNT(*) FROM [{CustomerContext.Schema}].[Outbox] WHERE [DeliveryComplete] = 0 AND [DeliveryAborted] = 0";
                     var result = await command.ExecuteScalarAsync();
                     var pendingCount = Convert.ToInt32(result);