Class LocalEventBus
Implements EventBus as Singleton pattern.
Inheritance
System.Object
LocalEventBus
Assembly: Volo.Abp.EventBus.dll
Syntax
public class LocalEventBus : EventBusBase, ILocalEventBus, IEventBus, ISingletonDependency
Constructors
LocalEventBus(IOptions<AbpLocalEventBusOptions>, IServiceScopeFactory, ICurrentTenant)
Declaration
public LocalEventBus(IOptions<AbpLocalEventBusOptions> options, IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant)
Parameters
Properties
HandlerFactories
Declaration
protected ConcurrentDictionary<Type, List<IEventHandlerFactory>> HandlerFactories { get; }
Property Value
Logger
Declaration
public ILogger<LocalEventBus> Logger { get; set; }
Property Value
Options
Declaration
protected AbpLocalEventBusOptions Options { get; }
Property Value
Methods
GetHandlerFactories(Type)
Declaration
protected override IEnumerable<EventBusBase.EventTypeWithEventHandlerFactories> GetHandlerFactories(Type eventType)
Parameters
Type |
Name |
Description |
Type |
eventType |
|
Returns
Overrides
PublishAsync(Type, Object)
Declaration
public override Task PublishAsync(Type eventType, object eventData)
Parameters
Type |
Name |
Description |
Type |
eventType |
|
System.Object |
eventData |
|
Returns
Overrides
Subscribe(Type, IEventHandlerFactory)
Declaration
public override IDisposable Subscribe(Type eventType, IEventHandlerFactory factory)
Parameters
Returns
Type |
Description |
IDisposable |
|
Overrides
Subscribe<TEvent>(ILocalEventHandler<TEvent>)
Declaration
public virtual IDisposable Subscribe<TEvent>(ILocalEventHandler<TEvent> handler)
where TEvent : class
Parameters
Returns
Type |
Description |
IDisposable |
|
Type Parameters
Unsubscribe(Type, IEventHandler)
Declaration
public override void Unsubscribe(Type eventType, IEventHandler handler)
Parameters
Overrides
Unsubscribe(Type, IEventHandlerFactory)
Declaration
public override void Unsubscribe(Type eventType, IEventHandlerFactory factory)
Parameters
Overrides
Unsubscribe<TEvent>(Func<TEvent, Task>)
Declaration
public override void Unsubscribe<TEvent>(Func<TEvent, Task> action)
where TEvent : class
Parameters
Type |
Name |
Description |
Func<TEvent, Task> |
action |
|
Type Parameters
Overrides
Volo.Abp.EventBus.EventBusBase.Unsubscribe<TEvent>(Func<TEvent, Task>)
UnsubscribeAll(Type)
Declaration
public override void UnsubscribeAll(Type eventType)
Parameters
Type |
Name |
Description |
Type |
eventType |
|
Overrides
Implements
Extension Methods