This is the default internal service bus implementation. It is not suitable for distributed hosting configurations.

public sealed class InternalServiceBus: IServiceBus, IInitializableProvider
Inheritance:
ObjectInternalServiceBus
Implements:
IServiceBusIInitializableProvider

Constructors

InternalServiceBus(ILogger<InternalServiceBus>)

Properties

IsInitialized
Name

Methods

InitializeAsync()
add_MessageReceived(Func<MessageReceivedEventArgs, Task>)
remove_MessageReceived(Func<MessageReceivedEventArgs, Task>)
SendMessageAsync<T>(T, bool)