Class LocalDistributedEventBus

Inheritance

object

EventBusBase

DistributedEventBusBase

LocalDistributedEventBus

Implements

IDistributedEventBus

IEventBus

ISupportsEventBoxes

ISingletonDependency

Inherited Members

DistributedEventBusBase.Subscribe<TEvent>(IDistributedEventHandler<TEvent>)

DistributedEventBusBase.PublishAsync(Type, object, bool)

DistributedEventBusBase.PublishAsync<TEvent>(TEvent, bool, bool)

DistributedEventBusBase.AddToOutboxAsync(Type, object)

DistributedEventBusBase.AddToInboxAsync(string, string, Type, object, string)

DistributedEventBusBase.TriggerHandlersDirectAsync(Type, object)

DistributedEventBusBase.TriggerHandlersFromInboxAsync(Type, object, List<Exception>, InboxConfig)

DistributedEventBusBase.TriggerDistributedEventSentAsync(DistributedEventSent)

DistributedEventBusBase.TriggerDistributedEventReceivedAsync(DistributedEventReceived)

DistributedEventBusBase.GuidGenerator

DistributedEventBusBase.Clock

DistributedEventBusBase.AbpDistributedEventBusOptions

DistributedEventBusBase.LocalEventBus

DistributedEventBusBase.CorrelationIdProvider

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.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.Distributed

Assembly: Volo.Abp.EventBus.dll

Syntax

[Dependency(TryRegister = true)]
[ExposeServices(new Type[] { typeof(IDistributedEventBus), typeof(LocalDistributedEventBus) })]
public class LocalDistributedEventBus : DistributedEventBusBase, IDistributedEventBus, IEventBus, ISupportsEventBoxes, ISingletonDependency

Constructors

LocalDistributedEventBus(IServiceScopeFactory, ICurrentTenant, IUnitOfWorkManager, IOptions<AbpDistributedEventBusOptions>, IGuidGenerator, IClock, IEventHandlerInvoker, ILocalEventBus, ICorrelationIdProvider)

Declaration

public LocalDistributedEventBus(IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant, IUnitOfWorkManager unitOfWorkManager, IOptions<AbpDistributedEventBusOptions> abpDistributedEventBusOptions, IGuidGenerator guidGenerator, IClock clock, IEventHandlerInvoker eventHandlerInvoker, ILocalEventBus localEventBus, ICorrelationIdProvider correlationIdProvider)

Parameters

Type	Name	Description
IServiceScopeFactory	serviceScopeFactory
ICurrentTenant	currentTenant
IUnitOfWorkManager	unitOfWorkManager
IOptions<AbpDistributedEventBusOptions>	abpDistributedEventBusOptions
IGuidGenerator	guidGenerator
IClock	clock
IEventHandlerInvoker	eventHandlerInvoker
ILocalEventBus	localEventBus
ICorrelationIdProvider	correlationIdProvider

Properties

EventTypes

Declaration

protected ConcurrentDictionary<string, Type> EventTypes { get; }

Property Value

Type	Description
ConcurrentDictionary<string, Type>

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<EventTypeWithEventHandlerFactories> GetHandlerFactories(Type eventType)

Parameters

Type	Name	Description
Type	eventType

Returns

Type	Description
IEnumerable<EventTypeWithEventHandlerFactories>

Overrides

EventBusBase.GetHandlerFactories(Type)

OnAddToOutboxAsync(string, Type, object)

Declaration

protected override Task OnAddToOutboxAsync(string eventName, Type eventType, object eventData)

Parameters

Type	Name	Description
string	eventName
Type	eventType
object	eventData

Returns

Type	Description
Task

Overrides

DistributedEventBusBase.OnAddToOutboxAsync(string, Type, object)

ProcessFromInboxAsync(IncomingEventInfo, InboxConfig)

Declaration

public override Task ProcessFromInboxAsync(IncomingEventInfo incomingEvent, InboxConfig inboxConfig)

Parameters

Type	Name	Description
IncomingEventInfo	incomingEvent
InboxConfig	inboxConfig

Returns

Type	Description
Task

Overrides

DistributedEventBusBase.ProcessFromInboxAsync(IncomingEventInfo, InboxConfig)

PublishAsync(Type, object, bool, bool)

Declaration

public override Task PublishAsync(Type eventType, object eventData, bool onUnitOfWorkComplete = true, bool useOutbox = true)

Parameters

Type	Name	Description
Type	eventType
object	eventData
bool	onUnitOfWorkComplete
bool	useOutbox

Returns

Type	Description
Task

Overrides

DistributedEventBusBase.PublishAsync(Type, object, bool, bool)

PublishFromOutboxAsync(OutgoingEventInfo, OutboxConfig)

Declaration

public override Task PublishFromOutboxAsync(OutgoingEventInfo outgoingEvent, OutboxConfig outboxConfig)

Parameters

Type	Name	Description
OutgoingEventInfo	outgoingEvent
OutboxConfig	outboxConfig

Returns

Type	Description
Task

Overrides

DistributedEventBusBase.PublishFromOutboxAsync(OutgoingEventInfo, OutboxConfig)

PublishManyFromOutboxAsync(IEnumerable<OutgoingEventInfo>, OutboxConfig)

Declaration

public override Task PublishManyFromOutboxAsync(IEnumerable<OutgoingEventInfo> outgoingEvents, OutboxConfig outboxConfig)

Parameters

Type	Name	Description
IEnumerable<OutgoingEventInfo>	outgoingEvents
OutboxConfig	outboxConfig

Returns

Type	Description
Task

Overrides

DistributedEventBusBase.PublishManyFromOutboxAsync(IEnumerable<OutgoingEventInfo>, OutboxConfig)

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)

Serialize(object)

Declaration

protected override byte[] Serialize(object eventData)

Parameters

Type	Name	Description
object	eventData

Returns

Type	Description
byte[]

Overrides

DistributedEventBusBase.Serialize(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(ITypeList<IEventHandler>)

Declaration

public virtual void Subscribe(ITypeList<IEventHandler> handlers)

Parameters

Type	Name	Description
ITypeList<IEventHandler>	handlers

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

IDistributedEventBus

IEventBus

ISupportsEventBoxes

ISingletonDependency

Extension Methods

AbpObjectExtensions.As<T>(object)

AbpObjectExtensions.To<T>(object)

LockExtensions.Locking(object, Action)

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

AbpDistributedEventBusExtensions.AsSupportsEventBoxes(IDistributedEventBus)

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>)