Class KafkaDistributedEventBus

Inheritance

object

EventBusBase

DistributedEventBusBase

KafkaDistributedEventBus

Implements

IDistributedEventBus

IEventBus

ISupportsEventBoxes

ISingletonDependency

Inherited Members

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

DistributedEventBusBase.PublishAsync(Type, object, bool)

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

DistributedEventBusBase.PublishAsync(Type, object, 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.Kafka

Assembly: Volo.Abp.EventBus.Kafka.dll

Syntax

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

Constructors

KafkaDistributedEventBus(IServiceScopeFactory, ICurrentTenant, IUnitOfWorkManager, IOptions<AbpKafkaEventBusOptions>, IKafkaMessageConsumerFactory, IOptions<AbpDistributedEventBusOptions>, IKafkaSerializer, IProducerPool, IGuidGenerator, IClock, IEventHandlerInvoker, ILocalEventBus, ICorrelationIdProvider)

Declaration

public KafkaDistributedEventBus(IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant, IUnitOfWorkManager unitOfWorkManager, IOptions<AbpKafkaEventBusOptions> abpKafkaEventBusOptions, IKafkaMessageConsumerFactory messageConsumerFactory, IOptions<AbpDistributedEventBusOptions> abpDistributedEventBusOptions, IKafkaSerializer serializer, IProducerPool producerPool, IGuidGenerator guidGenerator, IClock clock, IEventHandlerInvoker eventHandlerInvoker, ILocalEventBus localEventBus, ICorrelationIdProvider correlationIdProvider)

Parameters

Type	Name	Description
IServiceScopeFactory	serviceScopeFactory
ICurrentTenant	currentTenant
IUnitOfWorkManager	unitOfWorkManager
IOptions<AbpKafkaEventBusOptions>	abpKafkaEventBusOptions
IKafkaMessageConsumerFactory	messageConsumerFactory
IOptions<AbpDistributedEventBusOptions>	abpDistributedEventBusOptions
IKafkaSerializer	serializer
IProducerPool	producerPool
IGuidGenerator	guidGenerator
IClock	clock
IEventHandlerInvoker	eventHandlerInvoker
ILocalEventBus	localEventBus
ICorrelationIdProvider	correlationIdProvider

Properties

AbpKafkaEventBusOptions

Declaration

protected AbpKafkaEventBusOptions AbpKafkaEventBusOptions { get; }

Property Value

Type	Description
AbpKafkaEventBusOptions

Consumer

Declaration

protected IKafkaMessageConsumer Consumer { get; }

Property Value

Type	Description
IKafkaMessageConsumer

EventTypes

Declaration

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

Property Value

Type	Description
ConcurrentDictionary<string, Type>

HandlerFactories

Declaration

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

Property Value

Type	Description
ConcurrentDictionary<Type, List<IEventHandlerFactory>>

MessageConsumerFactory

Declaration

protected IKafkaMessageConsumerFactory MessageConsumerFactory { get; }

Property Value

Type	Description
IKafkaMessageConsumerFactory

ProducerPool

Declaration

protected IProducerPool ProducerPool { get; }

Property Value

Type	Description
IProducerPool

Serializer

Declaration

protected IKafkaSerializer Serializer { get; }

Property Value

Type	Description
IKafkaSerializer

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)

Initialize()

Declaration

public void Initialize()

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)

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)

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

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