fix publisher di

Alex-Kum · GermanCoding · commit b9a727e58a98 · 2026-05-28T11:45:10.000Z
diff --git a/src/Motor.Extensions.Hosting.Publisher/PublisherBuilder.cs b/src/Motor.Extensions.Hosting.Publisher/PublisherBuilder.cs
@@ -43,7 +43,7 @@ public void AddPublisher<TPublisher>()
     public void AddPublisher<TPublisher>(Func<IServiceProvider, TPublisher> implementationFactory)
         where TPublisher : class, IRawMessagePublisher<TOutput>
     {
-        _serviceCollection.AddTransient(typeof(IRawMessagePublisher<TOutput>), typeof(TPublisher));
+        _serviceCollection.AddTransient<IRawMessagePublisher<TOutput>>(sp => implementationFactory(sp));
         _serviceCollection.AddTransient(implementationFactory);
         _serviceCollection.AddTransient<IMessageEncoder, NoOpMessageEncoder>();
         PublisherImplType = typeof(TypedMessagePublisher<TOutput, TPublisher>);

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ public void AddPublisher<TPublisher>()`
`43`	`43`	`public void AddPublisher<TPublisher>(Func<IServiceProvider, TPublisher> implementationFactory)`
`44`	`44`	`where TPublisher : class, IRawMessagePublisher<TOutput>`
`45`	`45`	`{`
`46`		`- _serviceCollection.AddTransient(typeof(IRawMessagePublisher<TOutput>), typeof(TPublisher));`
	`46`	`+ _serviceCollection.AddTransient<IRawMessagePublisher<TOutput>>(sp => implementationFactory(sp));`
`47`	`47`	`_serviceCollection.AddTransient(implementationFactory);`
`48`	`48`	`_serviceCollection.AddTransient<IMessageEncoder, NoOpMessageEncoder>();`
`49`	`49`	`PublisherImplType = typeof(TypedMessagePublisher<TOutput, TPublisher>);`