Class RebusDistributedEventBus

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

Constructors

RebusDistributedEventBus(IServiceScopeFactory, ICurrentTenant, IBus, IOptions<AbpDistributedEventBusOptions>, IOptions<AbpRebusEventBusOptions>)

Declaration
public RebusDistributedEventBus(IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant, IBus rebus, IOptions<AbpDistributedEventBusOptions> abpDistributedEventBusOptions, IOptions<AbpRebusEventBusOptions> abpEventBusRebusOptions)
Parameters
Type Name Description
IServiceScopeFactory serviceScopeFactory
ICurrentTenant currentTenant
IBus rebus
IOptions<AbpDistributedEventBusOptions> abpDistributedEventBusOptions
IOptions<AbpRebusEventBusOptions> abpEventBusRebusOptions

Properties

AbpDistributedEventBusOptions

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

AbpRebusEventBusOptions

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

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

Rebus

Declaration
protected IBus Rebus { get; }
Property Value
Type Description
IBus

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