Class LocalEventBus

Inheritance
object
EventBusBase
LocalEventBus
Implements
Inherited Members
object.GetType()
object.MemberwiseClone()
object.ToString()
object.Equals(object)
object.Equals(object, object)
object.ReferenceEquals(object, object)
object.GetHashCode()
Namespace: Volo.Abp.EventBus.Local
Assembly: Volo.Abp.EventBus.dll
Syntax
[ExposeServices(new Type[] { typeof(ILocalEventBus), typeof(LocalEventBus) })]
public class LocalEventBus : EventBusBase, ILocalEventBus, IEventBus, ISingletonDependency

Constructors

LocalEventBus(IOptions<AbpLocalEventBusOptions>, IServiceScopeFactory, ICurrentTenant, IUnitOfWorkManager, IEventHandlerInvoker)

Declaration
public LocalEventBus(IOptions<AbpLocalEventBusOptions> options, IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant, IUnitOfWorkManager unitOfWorkManager, IEventHandlerInvoker eventHandlerInvoker)
Parameters
Type Name Description
Microsoft.Extensions.Options.IOptions<TOptions><AbpLocalEventBusOptions> options
Microsoft.Extensions.DependencyInjection.IServiceScopeFactory serviceScopeFactory
ICurrentTenant currentTenant
IUnitOfWorkManager unitOfWorkManager
IEventHandlerInvoker eventHandlerInvoker

Properties

HandlerFactories

Declaration
protected ConcurrentDictionary<Type, List<IEventHandlerFactory>> HandlerFactories { get; }
Property Value
Type Description
System.Collections.Concurrent.ConcurrentDictionary<TKey, TValue><System.Type, System.Collections.Generic.List<T><IEventHandlerFactory>>

Logger

Declaration
public ILogger<LocalEventBus> Logger { get; set; }
Property Value
Type Description
Microsoft.Extensions.Logging.ILogger<TCategoryName><LocalEventBus>

Options

Declaration
protected AbpLocalEventBusOptions Options { get; }
Property Value
Type Description
AbpLocalEventBusOptions

Methods

AddToUnitOfWork(IUnitOfWork, UnitOfWorkEventRecord)

Declaration
protected override void AddToUnitOfWork(IUnitOfWork unitOfWork, UnitOfWorkEventRecord eventRecord)
Parameters
Type Name Description
IUnitOfWork unitOfWork
UnitOfWorkEventRecord eventRecord
Overrides

GetHandlerFactories(Type)

Declaration
protected override IEnumerable<EventBusBase.EventTypeWithEventHandlerFactories> GetHandlerFactories(Type eventType)
Parameters
Type Name Description
System.Type eventType
Returns
Type Description
System.Collections.Generic.IEnumerable<T><EventBusBase.EventTypeWithEventHandlerFactories>
Overrides

PublishAsync(LocalEventMessage)

Declaration
public virtual Task PublishAsync(LocalEventMessage localEventMessage)
Parameters
Type Name Description
LocalEventMessage localEventMessage
Returns
Type Description
System.Threading.Tasks.Task

PublishToEventBusAsync(Type, object)

Declaration
protected override Task PublishToEventBusAsync(Type eventType, object eventData)
Parameters
Type Name Description
System.Type eventType
object eventData
Returns
Type Description
System.Threading.Tasks.Task
Overrides

Subscribe(Type, IEventHandlerFactory)

Declaration
public override IDisposable Subscribe(Type eventType, IEventHandlerFactory factory)
Parameters
Type Name Description
System.Type eventType
IEventHandlerFactory factory
Returns
Type Description
System.IDisposable
Overrides

Subscribe<TEvent>(ILocalEventHandler<TEvent>)

Declaration
public virtual IDisposable Subscribe<TEvent>(ILocalEventHandler<TEvent> handler) where TEvent : class
Parameters
Type Name Description
ILocalEventHandler<TEvent> handler
Returns
Type Description
System.IDisposable
Type Parameters
Name Description
TEvent

Unsubscribe(Type, IEventHandler)

Declaration
public override void Unsubscribe(Type eventType, IEventHandler handler)
Parameters
Type Name Description
System.Type eventType
IEventHandler handler
Overrides

Unsubscribe(Type, IEventHandlerFactory)

Declaration
public override void Unsubscribe(Type eventType, IEventHandlerFactory factory)
Parameters
Type Name Description
System.Type eventType
IEventHandlerFactory factory
Overrides

Unsubscribe<TEvent>(Func<TEvent, Task>)

Declaration
public override void Unsubscribe<TEvent>(Func<TEvent, Task> action) where TEvent : class
Parameters
Type Name Description
System.Func<T, TResult><TEvent, System.Threading.Tasks.Task> action
Type Parameters
Name Description
TEvent
Overrides
Volo.Abp.EventBus.EventBusBase.Unsubscribe<TEvent>(System.Func<TEvent, System.Threading.Tasks.Task>)

UnsubscribeAll(Type)

Declaration
public override void UnsubscribeAll(Type eventType)
Parameters
Type Name Description
System.Type eventType
Overrides

Implements

Extension Methods