Class RabbitMqDistributedEventBus

Inheritance
object
EventBusBase
DistributedEventBusBase
RabbitMqDistributedEventBus
Implements
Inherited Members
Namespace: Volo.Abp.EventBus.RabbitMq
Assembly: Volo.Abp.EventBus.RabbitMQ.dll
Syntax
[Dependency(ReplaceServices = true)]
[ExposeServices(new Type[] { typeof(IDistributedEventBus), typeof(RabbitMqDistributedEventBus) })]
public class RabbitMqDistributedEventBus : DistributedEventBusBase, IDistributedEventBus, IEventBus, ISupportsEventBoxes, ISingletonDependency

Constructors

RabbitMqDistributedEventBus(IOptions<AbpRabbitMqEventBusOptions>, IConnectionPool, IRabbitMqSerializer, IServiceScopeFactory, IOptions<AbpDistributedEventBusOptions>, IRabbitMqMessageConsumerFactory, ICurrentTenant, IUnitOfWorkManager, IGuidGenerator, IClock, IEventHandlerInvoker, ILocalEventBus, ICorrelationIdProvider)

Declaration
public RabbitMqDistributedEventBus(IOptions<AbpRabbitMqEventBusOptions> options, IConnectionPool connectionPool, IRabbitMqSerializer serializer, IServiceScopeFactory serviceScopeFactory, IOptions<AbpDistributedEventBusOptions> distributedEventBusOptions, IRabbitMqMessageConsumerFactory messageConsumerFactory, ICurrentTenant currentTenant, IUnitOfWorkManager unitOfWorkManager, IGuidGenerator guidGenerator, IClock clock, IEventHandlerInvoker eventHandlerInvoker, ILocalEventBus localEventBus, ICorrelationIdProvider correlationIdProvider)
Parameters
Type Name Description
IOptions<AbpRabbitMqEventBusOptions> options
IConnectionPool connectionPool
IRabbitMqSerializer serializer
IServiceScopeFactory serviceScopeFactory
IOptions<AbpDistributedEventBusOptions> distributedEventBusOptions
IRabbitMqMessageConsumerFactory messageConsumerFactory
ICurrentTenant currentTenant
IUnitOfWorkManager unitOfWorkManager
IGuidGenerator guidGenerator
IClock clock
IEventHandlerInvoker eventHandlerInvoker
ILocalEventBus localEventBus
ICorrelationIdProvider correlationIdProvider

Properties

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

AddToUnitOfWork(IUnitOfWork, UnitOfWorkEventRecord)

Declaration
protected override void AddToUnitOfWork(IUnitOfWork unitOfWork, UnitOfWorkEventRecord eventRecord)
Parameters
Type Name Description
IUnitOfWork unitOfWork
UnitOfWorkEventRecord eventRecord
Overrides

GetHandlerFactories(Type)

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

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

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

PublishAsync(IModel, string, byte[], Dictionary<string, object>?, Guid?, string?)

Declaration
protected virtual Task PublishAsync(IModel channel, string eventName, byte[] body, Dictionary<string, object>? headersArguments = null, Guid? eventId = null, string? correlationId = null)
Parameters
Type Name Description
IModel channel
string eventName
byte[] body
Dictionary<string, object> headersArguments
Guid? eventId
string correlationId
Returns
Type Description
Task

PublishAsync(string, byte[], Dictionary<string, object>?, Guid?, string?)

Declaration
protected virtual Task PublishAsync(string eventName, byte[] body, Dictionary<string, object>? headersArguments = null, Guid? eventId = null, string? correlationId = null)
Parameters
Type Name Description
string eventName
byte[] body
Dictionary<string, object> headersArguments
Guid? eventId
string correlationId
Returns
Type Description
Task

PublishAsync(Type, object, Dictionary<string, object>?, Guid?, string?)

Declaration
public virtual Task PublishAsync(Type eventType, object eventData, Dictionary<string, object>? headersArguments = null, Guid? eventId = null, string? correlationId = null)
Parameters
Type Name Description
Type eventType
object eventData
Dictionary<string, object> headersArguments
Guid? eventId
string correlationId
Returns
Type Description
Task

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

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

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

Serialize(object)

Declaration
protected override byte[] Serialize(object eventData)
Parameters
Type Name Description
object eventData
Returns
Type Description
byte[]
Overrides

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

Unsubscribe(Type, IEventHandler)

Declaration
public override void Unsubscribe(Type eventType, IEventHandler handler)
Parameters
Type Name Description
Type eventType
IEventHandler handler
Overrides

Unsubscribe(Type, IEventHandlerFactory)

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

UnsubscribeAll(Type)

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

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

Implements

Extension Methods