#273 Wrap IOutboxMigrationService resolution in a scope

Signed-off-by: Richard Pringle <[email protected]>
zarusz · Jun 27, 2024 · f961a62 · f961a62
1 parent 0981d8d
commit f961a62
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/SlimMessageBus.Host.Outbox/Interceptors/OutboxSendingTask.cs b/src/SlimMessageBus.Host.Outbox/Interceptors/OutboxSendingTask.cs
@@ -106,15 +106,20 @@ public Task OnBusLifecycle(MessageBusLifecycleEventType eventType, IMessageBus b
 
     private static async Task MigrateSchema(IServiceProvider serviceProvider, CancellationToken cancellationToken)
     {
+        var scope = serviceProvider.CreateScope();
         try
         {
-            var outboxMigrationService = serviceProvider.GetRequiredService<IOutboxMigrationService>();
+            var outboxMigrationService = scope.ServiceProvider.GetRequiredService<IOutboxMigrationService>();
             await outboxMigrationService.Migrate(cancellationToken);
         }
         catch (Exception e)
         {
             throw new MessageBusException("Outbox schema migration failed", e);
         }
+        finally
+        {
+            await ((IAsyncDisposable)scope).DisposeAsync();
+        }
     }
 
     private Task EnsureMigrateSchema(IServiceProvider serviceProvider, CancellationToken cancellationToken)