Sorry if I've missed the code, but it looks like you have a hosted service for your BusControl (github.com/thatham/test/blob/maste...) but you never actually add the hosted service to your Startup.cs...
If you try to execute the tenant->post of service project, the message will be sent using "endpoint.Send" method. I also have a consumer class (Handler in CQRS) for the command, upon receiving the message the event will be registered in presisted event store database(here it's cosmos DB).
Then, I try to publish an event using IPublishEndpoint which is not working.
I'm unable to publish an event using IPublishEndpoint from ConsumerContext instance. The source code can be found here github.com/thatham/test
Appreciate your valuable suggestion
Sorry if I've missed the code, but it looks like you have a hosted service for your BusControl (github.com/thatham/test/blob/maste...) but you never actually add the hosted service to your Startup.cs...
It is mentioned here in a method called "services.AddRabbitMQDependencies()" in startup.cs
I see that now, thanks for pointing that out.
What exactly isn't working?
If you try to execute the tenant->post of service project, the message will be sent using "endpoint.Send" method. I also have a consumer class (Handler in CQRS) for the command, upon receiving the message the event will be registered in presisted event store database(here it's cosmos DB).
Then, I try to publish an event using IPublishEndpoint which is not working.
Looking forward to be hearing from you...