Class RabbitMqDistributedEventBus

Inheritance
System.Object
EventBusBase
RabbitMqDistributedEventBus
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.RabbitMq
Assembly: Volo.Abp.EventBus.RabbitMQ.dll
Syntax
public class RabbitMqDistributedEventBus : EventBusBase, IDistributedEventBus, IEventBus, ISingletonDependency

Constructors

RabbitMqDistributedEventBus(IOptions<AbpRabbitMqEventBusOptions>, IConnectionPool, IRabbitMqSerializer, IServiceScopeFactory, IOptions<AbpDistributedEventBusOptions>, IRabbitMqMessageConsumerFactory, ICurrentTenant)

Declaration
public RabbitMqDistributedEventBus(IOptions<AbpRabbitMqEventBusOptions> options, IConnectionPool connectionPool, IRabbitMqSerializer serializer, IServiceScopeFactory serviceScopeFactory, IOptions<AbpDistributedEventBusOptions> distributedEventBusOptions, IRabbitMqMessageConsumerFactory messageConsumerFactory, ICurrentTenant currentTenant)
Parameters
Type Name Description
IOptions<AbpRabbitMqEventBusOptions> options
IConnectionPool connectionPool
IRabbitMqSerializer serializer
IServiceScopeFactory serviceScopeFactory
IOptions<AbpDistributedEventBusOptions> distributedEventBusOptions
IRabbitMqMessageConsumerFactory messageConsumerFactory
ICurrentTenant currentTenant

Properties

AbpDistributedEventBusOptions

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

AbpRabbitMqEventBusOptions

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

ConnectionPool

Declaration
protected IConnectionPool ConnectionPool { get; }
Property Value
Type Description
IConnectionPool

Consumer

Declaration
protected IRabbitMqMessageConsumer Consumer { get; }
Property Value
Type Description
IRabbitMqMessageConsumer

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 IRabbitMqMessageConsumerFactory MessageConsumerFactory { get; }
Property Value
Type Description
IRabbitMqMessageConsumerFactory

Serializer

Declaration
protected IRabbitMqSerializer Serializer { get; }
Property Value
Type Description
IRabbitMqSerializer

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