- fixed ioc registrations

NinjaRocks · NinjaRocks · commit b63f46612a21 · 2025-07-23T22:37:45.000+01:00
diff --git a/src/SourceFlow/IocExtensions.cs b/src/SourceFlow/IocExtensions.cs
@@ -237,7 +237,7 @@ public static ISourceFlowConfig WithSaga<TAggregate, TSaga>(this ISourceFlowConf
                     .GetField("repository", BindingFlags.Instance | BindingFlags.NonPublic)
                     ?.SetValue(saga, c.GetRequiredService<IRepository>());
 
-                var dispatcher = c.GetRequiredService<ICommandDispatcher>();
+                var dispatcher = c.GetRequiredService<SagaDispatcher>();
                 dispatcher.Register(saga);
 
                 return (TSaga)saga;
@@ -483,7 +483,7 @@ public static ISourceFlowConfig WithSagas(this ISourceFlowConfig config, Func<Ty
 
                         if (index == 1)
                         {
-                            var dispatcher = c.GetRequiredService<ICommandDispatcher>();
+                            var dispatcher = c.GetRequiredService<SagaDispatcher>();
                             dispatcher.Register(sagaInstance);
                         }
 

Original file line number	Diff line number	Diff line change
`@@ -237,7 +237,7 @@ public static ISourceFlowConfig WithSaga<TAggregate, TSaga>(this ISourceFlowConf`
`237`	`237`	`.GetField("repository", BindingFlags.Instance \| BindingFlags.NonPublic)`
`238`	`238`	`?.SetValue(saga, c.GetRequiredService<IRepository>());`
`239`	`239`
`240`		`- var dispatcher = c.GetRequiredService<ICommandDispatcher>();`
	`240`	`+ var dispatcher = c.GetRequiredService<SagaDispatcher>();`
`241`	`241`	`dispatcher.Register(saga);`
`242`	`242`
`243`	`243`	`return (TSaga)saga;`
`@@ -483,7 +483,7 @@ public static ISourceFlowConfig WithSagas(this ISourceFlowConfig config, Func<Ty`
`483`	`483`
`484`	`484`	`if (index == 1)`
`485`	`485`	`{`
`486`		`- var dispatcher = c.GetRequiredService<ICommandDispatcher>();`
	`486`	`+ var dispatcher = c.GetRequiredService<SagaDispatcher>();`
`487`	`487`	`dispatcher.Register(sagaInstance);`
`488`	`488`	`}`
`489`	`489`