Class EventBusBase
Assembly: Volo.Abp.EventBus.dll
Syntax
public abstract class EventBusBase : IEventBus
Constructors
EventBusBase(IServiceScopeFactory, ICurrentTenant, IUnitOfWorkManager, IEventHandlerInvoker)
Declaration
protected EventBusBase(IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant, IUnitOfWorkManager unitOfWorkManager, IEventHandlerInvoker eventHandlerInvoker)
Parameters
Properties
CurrentTenant
Declaration
protected ICurrentTenant CurrentTenant { get; }
Property Value
EventHandlerInvoker
Declaration
protected IEventHandlerInvoker EventHandlerInvoker { get; }
Property Value
ServiceScopeFactory
Declaration
protected IServiceScopeFactory ServiceScopeFactory { get; }
Property Value
UnitOfWorkManager
Declaration
protected IUnitOfWorkManager UnitOfWorkManager { get; }
Property Value
Methods
AddToUnitOfWork(IUnitOfWork, UnitOfWorkEventRecord)
Declaration
protected abstract void AddToUnitOfWork(IUnitOfWork unitOfWork, UnitOfWorkEventRecord eventRecord)
Parameters
GetEventDataTenantId(object)
Declaration
protected virtual Guid? GetEventDataTenantId(object eventData)
Parameters
| Type |
Name |
Description |
| object |
eventData |
|
Returns
GetHandlerFactories(Type)
Declaration
protected abstract IEnumerable<EventBusBase.EventTypeWithEventHandlerFactories> GetHandlerFactories(Type eventType)
Parameters
| Type |
Name |
Description |
| Type |
eventType |
|
Returns
InvokeEventHandlerAsync(IEventHandler, object, Type)
Declaration
protected virtual Task InvokeEventHandlerAsync(IEventHandler eventHandler, object eventData, Type eventType)
Parameters
Returns
PublishAsync(Type, object, bool)
Declaration
public virtual Task PublishAsync(Type eventType, object eventData, bool onUnitOfWorkComplete = true)
Parameters
| Type |
Name |
Description |
| Type |
eventType |
|
| object |
eventData |
|
| bool |
onUnitOfWorkComplete |
|
Returns
PublishAsync<TEvent>(TEvent, bool)
Declaration
public Task PublishAsync<TEvent>(TEvent eventData, bool onUnitOfWorkComplete = true) where TEvent : class
Parameters
| Type |
Name |
Description |
| TEvent |
eventData |
|
| bool |
onUnitOfWorkComplete |
|
Returns
Type Parameters
PublishToEventBusAsync(Type, object)
Declaration
protected abstract Task PublishToEventBusAsync(Type eventType, object eventData)
Parameters
| Type |
Name |
Description |
| Type |
eventType |
|
| object |
eventData |
|
Returns
Subscribe(Type, IEventHandler)
Declaration
public virtual IDisposable Subscribe(Type eventType, IEventHandler handler)
Parameters
Returns
Subscribe(Type, IEventHandlerFactory)
Declaration
public abstract IDisposable Subscribe(Type eventType, IEventHandlerFactory factory)
Parameters
Returns
SubscribeHandlers(ITypeList<IEventHandler>)
Declaration
protected virtual void SubscribeHandlers(ITypeList<IEventHandler> handlers)
Parameters
Subscribe<TEvent>(Func<TEvent, Task>)
Declaration
public virtual IDisposable Subscribe<TEvent>(Func<TEvent, Task> action) where TEvent : class
Parameters
| Type |
Name |
Description |
| Func<TEvent, Task> |
action |
|
Returns
Type Parameters
Subscribe<TEvent>(IEventHandlerFactory)
Declaration
public virtual IDisposable Subscribe<TEvent>(IEventHandlerFactory factory) where TEvent : class
Parameters
Returns
Type Parameters
Subscribe<TEvent, THandler>()
Declaration
public virtual IDisposable Subscribe<TEvent, THandler>() where TEvent : class where THandler : IEventHandler, new()
Returns
Type Parameters
| Name |
Description |
| TEvent |
|
| THandler |
|
ThrowOriginalExceptions(Type, List<Exception>)
Declaration
protected void ThrowOriginalExceptions(Type eventType, List<Exception> exceptions)
Parameters
TriggerHandlerAsync(IEventHandlerFactory, Type, object, List<Exception>, InboxConfig?)
Declaration
protected virtual Task TriggerHandlerAsync(IEventHandlerFactory asyncHandlerFactory, Type eventType, object eventData, List<Exception> exceptions, InboxConfig? inboxConfig = null)
Parameters
Returns
TriggerHandlersAsync(Type, object)
Declaration
public virtual Task TriggerHandlersAsync(Type eventType, object eventData)
Parameters
| Type |
Name |
Description |
| Type |
eventType |
|
| object |
eventData |
|
Returns
TriggerHandlersAsync(Type, object, List<Exception>, InboxConfig?)
Declaration
protected virtual Task TriggerHandlersAsync(Type eventType, object eventData, List<Exception> exceptions, InboxConfig? inboxConfig = null)
Parameters
Returns
Unsubscribe(Type, IEventHandler)
Declaration
public abstract void Unsubscribe(Type eventType, IEventHandler handler)
Parameters
Unsubscribe(Type, IEventHandlerFactory)
Declaration
public abstract void Unsubscribe(Type eventType, IEventHandlerFactory factory)
Parameters
UnsubscribeAll(Type)
Declaration
public abstract void UnsubscribeAll(Type eventType)
Parameters
| Type |
Name |
Description |
| Type |
eventType |
|
UnsubscribeAll<TEvent>()
Declaration
public virtual void UnsubscribeAll<TEvent>() where TEvent : class
Type Parameters
Unsubscribe<TEvent>(Func<TEvent, Task>)
Declaration
public abstract void Unsubscribe<TEvent>(Func<TEvent, Task> action) where TEvent : class
Parameters
| Type |
Name |
Description |
| Func<TEvent, Task> |
action |
|
Type Parameters
Unsubscribe<TEvent>(IEventHandlerFactory)
Declaration
public virtual void Unsubscribe<TEvent>(IEventHandlerFactory factory) where TEvent : class
Parameters
Type Parameters
Unsubscribe<TEvent>(ILocalEventHandler<TEvent>)
Declaration
public virtual void Unsubscribe<TEvent>(ILocalEventHandler<TEvent> handler) where TEvent : class
Parameters
Type Parameters
Implements
Extension Methods