commit use use CreateAsyncScope

tjain-ms · tjain-ms · commit d6ea0cbdf510 · 2023-03-27T23:48:14.000+05:30
diff --git a/src/BuildingBlocks/EventBus/EventBusRabbitMQ/EventBusRabbitMQ.cs b/src/BuildingBlocks/EventBus/EventBusRabbitMQ/EventBusRabbitMQ.cs
@@ -241,7 +241,7 @@ private async Task ProcessEvent(string eventName, string message)
 
         if (_subsManager.HasSubscriptionsForEvent(eventName))
         {
-            using var scope = _serviceProvider.CreateScope();
+            await using var scope = _serviceProvider.CreateAsyncScope();
             var subscriptions = _subsManager.GetHandlersForEvent(eventName);
             foreach (var subscription in subscriptions)
             {
diff --git a/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs b/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs
@@ -151,7 +151,7 @@ private async Task<bool> ProcessEvent(string eventName, string message)
         var processed = false;
         if (_subsManager.HasSubscriptionsForEvent(eventName))
         {
-            var scope = _serviceProvider.CreateScope();
+            await using var scope = _serviceProvider.CreateAsyncScope();
             var subscriptions = _subsManager.GetHandlersForEvent(eventName);
             foreach (var subscription in subscriptions)
             {

Original file line number	Diff line number	Diff line change
`@@ -241,7 +241,7 @@ private async Task ProcessEvent(string eventName, string message)`
`241`	`241`
`242`	`242`	`if (_subsManager.HasSubscriptionsForEvent(eventName))`
`243`	`243`	`{`
`244`		`- using var scope = _serviceProvider.CreateScope();`
	`244`	`+ await using var scope = _serviceProvider.CreateAsyncScope();`
`245`	`245`	`var subscriptions = _subsManager.GetHandlersForEvent(eventName);`
`246`	`246`	`foreach (var subscription in subscriptions)`
`247`	`247`	`{`
Original file line number	Diff line number	Diff line change
`@@ -151,7 +151,7 @@ private async Task<bool> ProcessEvent(string eventName, string message)`
`151`	`151`	`var processed = false;`
`152`	`152`	`if (_subsManager.HasSubscriptionsForEvent(eventName))`
`153`	`153`	`{`
`154`		`- var scope = _serviceProvider.CreateScope();`
	`154`	`+ await using var scope = _serviceProvider.CreateAsyncScope();`
`155`	`155`	`var subscriptions = _subsManager.GetHandlersForEvent(eventName);`
`156`	`156`	`foreach (var subscription in subscriptions)`
`157`	`157`	`{`