(fix) messagebus invocation

marcwittke · marcwittke · commit e073b13927bc · 2022-06-16T10:48:43.000-03:00
diff --git a/src/abstractions/Backend.Fx/Patterns/EventAggregation/Integration/MessageBusApplication.cs b/src/abstractions/Backend.Fx/Patterns/EventAggregation/Integration/MessageBusApplication.cs
@@ -13,8 +13,11 @@ public MessageBusApplication(IMessageBus messageBus, IBackendFxApplication appli
         {
             application.CompositionRoot.RegisterModules(new MessageBusModule(messageBus, application.Assemblies));
             _messageBus = messageBus;
-            Invoker = new RaiseIntegrationEventsInvokerDecorator(application.CompositionRoot, base.Invoker);
+            var invoker = new RaiseIntegrationEventsInvokerDecorator(application.CompositionRoot, base.Invoker);
+            _messageBus.ProvideInvoker(invoker);
+            Invoker = invoker;
             AsyncInvoker = new RaiseIntegrationEventsAsyncInvokerDecorator(application.CompositionRoot, base.AsyncInvoker);
+            
         }
 
         public override async Task BootAsync(CancellationToken cancellationToken = default)

Original file line number	Diff line number	Diff line change
`@@ -13,8 +13,11 @@ public MessageBusApplication(IMessageBus messageBus, IBackendFxApplication appli`
`13`	`13`	`{`
`14`	`14`	`application.CompositionRoot.RegisterModules(new MessageBusModule(messageBus, application.Assemblies));`
`15`	`15`	`_messageBus = messageBus;`
`16`		`- Invoker = new RaiseIntegrationEventsInvokerDecorator(application.CompositionRoot, base.Invoker);`
	`16`	`+ var invoker = new RaiseIntegrationEventsInvokerDecorator(application.CompositionRoot, base.Invoker);`
	`17`	`+ _messageBus.ProvideInvoker(invoker);`
	`18`	`+ Invoker = invoker;`
`17`	`19`	`AsyncInvoker = new RaiseIntegrationEventsAsyncInvokerDecorator(application.CompositionRoot, base.AsyncInvoker);`
	`20`	`+`
`18`	`21`	`}`
`19`	`22`
`20`	`23`	`public override async Task BootAsync(CancellationToken cancellationToken = default)`