You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Given a Hybrid Bus with an In-Memory bus as the child,
When publishing a domain event for the in-memory bus that has no consumer or handler registered,
We are getting the following exception raised by Hybrid Bus:
SlimMessageBus.Host.ConfigurationMessageBusException: Could not find any bus that produces the message type: <MessageType>
Sample:
// will raise the exceptionawaitMessageBus.Current.Publish(newCustomerCreatedEvent(Id))
Configuration (shortened):
services.AddSlimMessageBus(mbb =>{mbb.AddChildBus("Memory", builder =>{varnamespaceNames=new[]{"DomainEventHandlers","QueryHandlers","CommandHandlers"};builder.WithProviderMemory().AutoDeclareFrom(typeof(CustomerCommandHandler).Assembly,consumerTypeFilter:(consumerType)=>Array.Exists(namespaceNames, x =>consumerType.Namespace.Contains(x,StringComparison.InvariantCultureIgnoreCase)));}).AddChildBus("AzureSB", builder =>{builder// ....WithProviderServiceBus(cfg =>{});});});
While the AutoDeclareFrom() did not find any handler/consumer that consumes the type CustomerCreatedEvent, the hybrid should still not raise an exception. At least we could have a configuration on the hybrid to not fail and perhaps just log a one-time WARN log.
The text was updated successfully, but these errors were encountered:
Given a Hybrid Bus with an In-Memory bus as the child,
When publishing a domain event for the in-memory bus that has no consumer or handler registered,
We are getting the following exception raised by Hybrid Bus:
Sample:
Configuration (shortened):
While the
AutoDeclareFrom()
did not find any handler/consumer that consumes the typeCustomerCreatedEvent
, the hybrid should still not raise an exception. At least we could have a configuration on the hybrid to not fail and perhaps just log a one-time WARN log.The text was updated successfully, but these errors were encountered: