Class KafkaDistributedEventBus

Inheritance
System.Object
EventBusBase
KafkaDistributedEventBus
Implements
ISingletonDependency
Inherited Members
Volo.Abp.EventBus.EventBusBase.Subscribe<TEvent>(Func<, >)
Volo.Abp.EventBus.EventBusBase.Unsubscribe<TEvent>(Func<, >)
Volo.Abp.EventBus.EventBusBase.TriggerHandlersAsync(Type, System.Object, List<>)
Volo.Abp.EventBus.EventBusBase.TriggerHandlerAsync(Volo.Abp.EventBus.IEventHandlerFactory, Type, System.Object, List<>)
Namespace: Volo.Abp.EventBus.Kafka
Assembly: Volo.Abp.EventBus.Kafka.dll
Syntax
public class KafkaDistributedEventBus : EventBusBase, IDistributedEventBus, IEventBus, ISingletonDependency

Constructors

KafkaDistributedEventBus(IServiceScopeFactory, ICurrentTenant, IOptions<AbpKafkaEventBusOptions>, IKafkaMessageConsumerFactory, IOptions<AbpDistributedEventBusOptions>, IKafkaSerializer, IProducerPool)

Declaration
public KafkaDistributedEventBus(IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant, IOptions<AbpKafkaEventBusOptions> abpKafkaEventBusOptions, IKafkaMessageConsumerFactory messageConsumerFactory, IOptions<AbpDistributedEventBusOptions> abpDistributedEventBusOptions, IKafkaSerializer serializer, IProducerPool producerPool)
Parameters
Type Name Description
IServiceScopeFactory serviceScopeFactory
ICurrentTenant currentTenant
IOptions<AbpKafkaEventBusOptions> abpKafkaEventBusOptions
IKafkaMessageConsumerFactory messageConsumerFactory
IOptions<AbpDistributedEventBusOptions> abpDistributedEventBusOptions
IKafkaSerializer serializer
IProducerPool producerPool

Properties

AbpDistributedEventBusOptions

Declaration
protected AbpDistributedEventBusOptions AbpDistributedEventBusOptions { get; }
Property Value
Type Description
AbpDistributedEventBusOptions

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

GetHandlerFactories(Type)

Declaration
protected override IEnumerable<EventBusBase.EventTypeWithEventHandlerFactories> GetHandlerFactories(Type eventType)
Parameters
Type Name Description
Type eventType
Returns
Type Description
IEnumerable<EventBusBase.EventTypeWithEventHandlerFactories>

Initialize()

Declaration
public void Initialize()

PublishAsync(Type, Object)

Declaration
public override Task PublishAsync(Type eventType, object eventData)
Parameters
Type Name Description
Type eventType
System.Object eventData
Returns
Type Description
Task

Subscribe(Type, IEventHandlerFactory)

Declaration
public override IDisposable Subscribe(Type eventType, IEventHandlerFactory factory)
Parameters
Type Name Description
Type eventType
IEventHandlerFactory factory
Returns
Type Description
IDisposable

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

Unsubscribe(Type, IEventHandlerFactory)

Declaration
public override void Unsubscribe(Type eventType, IEventHandlerFactory factory)
Parameters
Type Name Description
Type eventType
IEventHandlerFactory factory

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

Declaration
public override void Unsubscribe<TEvent>(Func<TEvent, Task> action)
Parameters
Type Name Description
Func<TEvent, Task> action
Type Parameters
Name Description
TEvent

UnsubscribeAll(Type)

Declaration
public override void UnsubscribeAll(Type eventType)
Parameters
Type Name Description
Type eventType

Implements

ISingletonDependency

Extension Methods