Class LocalEventBus

Inheritance

object

EventBusBase

LocalEventBus

Implements

ILocalEventBus

IEventBus

ISingletonDependency

Inherited Members

EventBusBase.Subscribe<TEvent>(Func<TEvent, Task>)

EventBusBase.Subscribe<TEvent, THandler>()

EventBusBase.Subscribe(Type, IEventHandler)

EventBusBase.Subscribe<TEvent>(IEventHandlerFactory)

EventBusBase.Unsubscribe<TEvent>(ILocalEventHandler<TEvent>)

EventBusBase.Unsubscribe<TEvent>(IEventHandlerFactory)

EventBusBase.UnsubscribeAll<TEvent>()

EventBusBase.PublishAsync<TEvent>(TEvent, bool)

EventBusBase.PublishAsync(Type, object, bool)

EventBusBase.TriggerHandlersAsync(Type, object)

EventBusBase.TriggerHandlersAsync(Type, object, List<Exception>, InboxConfig)

EventBusBase.ThrowOriginalExceptions(Type, List<Exception>)

EventBusBase.SubscribeHandlers(ITypeList<IEventHandler>)

EventBusBase.TriggerHandlerAsync(IEventHandlerFactory, Type, object, List<Exception>, InboxConfig)

EventBusBase.InvokeEventHandlerAsync(IEventHandler, object, Type)

EventBusBase.GetEventDataTenantId(object)

EventBusBase.ServiceScopeFactory

EventBusBase.CurrentTenant

EventBusBase.UnitOfWorkManager

EventBusBase.EventHandlerInvoker

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
IOptions<AbpLocalEventBusOptions>	options
IServiceScopeFactory	serviceScopeFactory
ICurrentTenant	currentTenant
IUnitOfWorkManager	unitOfWorkManager
IEventHandlerInvoker	eventHandlerInvoker

Properties

HandlerFactories

Declaration

protected ConcurrentDictionary<Type, List<IEventHandlerFactory>> HandlerFactories { get; }

Property Value

Type	Description
ConcurrentDictionary<Type, List<IEventHandlerFactory>>

Logger

Declaration

public ILogger<LocalEventBus> Logger { get; set; }

Property Value

Type	Description
ILogger<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

EventBusBase.AddToUnitOfWork(IUnitOfWork, UnitOfWorkEventRecord)

GetHandlerFactories(Type)

Declaration

protected override IEnumerable<EventBusBase.EventTypeWithEventHandlerFactories> GetHandlerFactories(Type eventType)

Parameters

Type	Name	Description
Type	eventType

Returns

Type	Description
IEnumerable<EventBusBase.EventTypeWithEventHandlerFactories>

Overrides

EventBusBase.GetHandlerFactories(Type)

PublishAsync(LocalEventMessage)

Declaration

public virtual Task PublishAsync(LocalEventMessage localEventMessage)

Parameters

Type	Name	Description
LocalEventMessage	localEventMessage

Returns

Type	Description
Task

PublishToEventBusAsync(Type, object)

Declaration

protected override Task PublishToEventBusAsync(Type eventType, object eventData)

Parameters

Type	Name	Description
Type	eventType
object	eventData

Returns

Type	Description
Task

Overrides

EventBusBase.PublishToEventBusAsync(Type, object)

Subscribe(Type, IEventHandlerFactory)

Declaration

public override IDisposable Subscribe(Type eventType, IEventHandlerFactory factory)

Parameters

Type	Name	Description
Type	eventType
IEventHandlerFactory	factory

Returns

Type	Description
IDisposable

Overrides

EventBusBase.Subscribe(Type, IEventHandlerFactory)

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
IDisposable

Type Parameters

Name	Description
TEvent

Unsubscribe(Type, IEventHandler)

Declaration

public override void Unsubscribe(Type eventType, IEventHandler handler)

Parameters

Type	Name	Description
Type	eventType
IEventHandler	handler

Overrides

EventBusBase.Unsubscribe(Type, IEventHandler)

Unsubscribe(Type, IEventHandlerFactory)

Declaration

public override void Unsubscribe(Type eventType, IEventHandlerFactory factory)

Parameters

Type	Name	Description
Type	eventType
IEventHandlerFactory	factory

Overrides

EventBusBase.Unsubscribe(Type, IEventHandlerFactory)

UnsubscribeAll(Type)

Declaration

public override void UnsubscribeAll(Type eventType)

Parameters

Type	Name	Description
Type	eventType

Overrides

EventBusBase.UnsubscribeAll(Type)

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

Name	Description
TEvent

Overrides

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

Implements

ILocalEventBus

IEventBus

ISingletonDependency

Extension Methods

AbpObjectExtensions.As<T>(object)

AbpObjectExtensions.To<T>(object)

LockExtensions.Locking(object, Action)

LockExtensions.Locking<TResult>(object, Func<TResult>)

AbpObjectExtensions.If<T>(T, bool, Action<T>)

AbpObjectExtensions.If<T>(T, bool, Func<T, T>)

AbpObjectExtensions.IsIn<T>(T, IEnumerable<T>)

AbpObjectExtensions.IsIn<T>(T, params T[])

AbpQueryableExtensions.OrderByIf<T, TQueryable>(TQueryable, bool, string)

AbpQueryableExtensions.PageBy<T, TQueryable>(TQueryable, int, int)

AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, bool>>)

AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, int, bool>>)

AbpOpenIddictQueryableExtensions.SkipIf<T, TQueryable>(TQueryable, bool, int?)

AbpOpenIddictQueryableExtensions.TakeIf<T, TQueryable>(TQueryable, bool, int?)

LockExtensions.Locking<T>(T, Action<T>)

LockExtensions.Locking<T, TResult>(T, Func<T, TResult>)