Class DistributedEventBusBase

Inheritance

object

EventBusBase

DistributedEventBusBase

AzureDistributedEventBus

DaprDistributedEventBus

KafkaDistributedEventBus

RabbitMqDistributedEventBus

RebusDistributedEventBus

Implements

IDistributedEventBus

IEventBus

ISupportsEventBoxes

Inherited Members

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

EventBusBase.Subscribe<TEvent, THandler>()

EventBusBase.Subscribe(Type, IEventHandler)

EventBusBase.Subscribe<TEvent>(IEventHandlerFactory)

EventBusBase.Subscribe(Type, IEventHandlerFactory)

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

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

EventBusBase.Unsubscribe(Type, IEventHandler)

EventBusBase.Unsubscribe<TEvent>(IEventHandlerFactory)

EventBusBase.Unsubscribe(Type, IEventHandlerFactory)

EventBusBase.UnsubscribeAll<TEvent>()

EventBusBase.UnsubscribeAll(Type)

EventBusBase.PublishAsync<TEvent>(TEvent, bool)

EventBusBase.PublishToEventBusAsync(Type, object)

EventBusBase.AddToUnitOfWork(IUnitOfWork, UnitOfWorkEventRecord)

EventBusBase.TriggerHandlersAsync(Type, object)

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

EventBusBase.ThrowOriginalExceptions(Type, List<Exception>)

EventBusBase.SubscribeHandlers(ITypeList<IEventHandler>)

EventBusBase.GetHandlerFactories(Type)

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

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

public abstract class DistributedEventBusBase : EventBusBase, IDistributedEventBus, IEventBus, ISupportsEventBoxes

Constructors

DistributedEventBusBase(IServiceScopeFactory, ICurrentTenant, IUnitOfWorkManager, IOptions<AbpDistributedEventBusOptions>, IGuidGenerator, IClock, IEventHandlerInvoker)

Declaration

protected DistributedEventBusBase(IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant, IUnitOfWorkManager unitOfWorkManager, IOptions<AbpDistributedEventBusOptions> abpDistributedEventBusOptions, IGuidGenerator guidGenerator, IClock clock, IEventHandlerInvoker eventHandlerInvoker)

Parameters

Type	Name	Description
Microsoft.Extensions.DependencyInjection.IServiceScopeFactory	serviceScopeFactory
ICurrentTenant	currentTenant
IUnitOfWorkManager	unitOfWorkManager
Microsoft.Extensions.Options.IOptions<TOptions><AbpDistributedEventBusOptions>	abpDistributedEventBusOptions
IGuidGenerator	guidGenerator
IClock	clock
IEventHandlerInvoker	eventHandlerInvoker

Properties

AbpDistributedEventBusOptions

Declaration

protected AbpDistributedEventBusOptions AbpDistributedEventBusOptions { get; }

Property Value

Type	Description
AbpDistributedEventBusOptions

Clock

Declaration

protected IClock Clock { get; }

Property Value

Type	Description
IClock

GuidGenerator

Declaration

protected IGuidGenerator GuidGenerator { get; }

Property Value

Type	Description
IGuidGenerator

Methods

AddToInboxAsync(string, string, Type, byte[])

Declaration

protected Task<bool> AddToInboxAsync(string messageId, string eventName, Type eventType, byte[] eventBytes)

Parameters

Type	Name	Description
string	messageId
string	eventName
System.Type	eventType
byte[]	eventBytes

Returns

Type	Description
System.Threading.Tasks.Task<TResult><bool>

ProcessFromInboxAsync(IncomingEventInfo, InboxConfig)

Declaration

public abstract Task ProcessFromInboxAsync(IncomingEventInfo incomingEvent, InboxConfig inboxConfig)

Parameters

Type	Name	Description
IncomingEventInfo	incomingEvent
InboxConfig	inboxConfig

Returns

Type	Description
System.Threading.Tasks.Task

PublishAsync(Type, object, bool, bool)

Declaration

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

Parameters

Type	Name	Description
System.Type	eventType
object	eventData
bool	onUnitOfWorkComplete
bool	useOutbox

Returns

Type	Description
System.Threading.Tasks.Task

PublishAsync(Type, object, bool)

Declaration

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

Parameters

Type	Name	Description
System.Type	eventType
object	eventData
bool	onUnitOfWorkComplete

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

EventBusBase.PublishAsync(Type, object, bool)

PublishAsync<TEvent>(TEvent, bool, bool)

Declaration

public Task PublishAsync<TEvent>(TEvent eventData, bool onUnitOfWorkComplete = true, bool useOutbox = true) where TEvent : class

Parameters

Type	Name	Description
TEvent	eventData
bool	onUnitOfWorkComplete
bool	useOutbox

Returns

Type	Description
System.Threading.Tasks.Task

Type Parameters

Name	Description
TEvent

PublishFromOutboxAsync(OutgoingEventInfo, OutboxConfig)

Declaration

public abstract Task PublishFromOutboxAsync(OutgoingEventInfo outgoingEvent, OutboxConfig outboxConfig)

Parameters

Type	Name	Description
OutgoingEventInfo	outgoingEvent
OutboxConfig	outboxConfig

Returns

Type	Description
System.Threading.Tasks.Task

PublishManyFromOutboxAsync(IEnumerable<OutgoingEventInfo>, OutboxConfig)

Declaration

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

Parameters

Type	Name	Description
System.Collections.Generic.IEnumerable<T><OutgoingEventInfo>	outgoingEvents
OutboxConfig	outboxConfig

Returns

Type	Description
System.Threading.Tasks.Task

Serialize(object)

Declaration

protected abstract byte[] Serialize(object eventData)

Parameters

Type	Name	Description
object	eventData

Returns

Type	Description
byte[]

Subscribe<TEvent>(IDistributedEventHandler<TEvent>)

Declaration

public IDisposable Subscribe<TEvent>(IDistributedEventHandler<TEvent> handler) where TEvent : class

Parameters

Type	Name	Description
IDistributedEventHandler<TEvent>	handler

Returns

Type	Description
System.IDisposable

Type Parameters

Name	Description
TEvent

Implements

IDistributedEventBus

IEventBus

ISupportsEventBoxes

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

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

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

AbpDistributedEventBusExtensions.AsSupportsEventBoxes(IDistributedEventBus)