Class OutboxSender

Inheritance
object
OutboxSender
Implements
Inherited Members
object.GetType()
object.MemberwiseClone()
object.ToString()
object.Equals(object)
object.Equals(object, object)
object.ReferenceEquals(object, object)
object.GetHashCode()
Namespace: Volo.Abp.EventBus.Distributed
Assembly: Volo.Abp.EventBus.dll
Syntax
public class OutboxSender : IOutboxSender, ITransientDependency

Constructors

OutboxSender(IServiceProvider, AbpAsyncTimer, IDistributedEventBus, IAbpDistributedLock, IOptions<AbpEventBusBoxesOptions>)

Declaration
public OutboxSender(IServiceProvider serviceProvider, AbpAsyncTimer timer, IDistributedEventBus distributedEventBus, IAbpDistributedLock distributedLock, IOptions<AbpEventBusBoxesOptions> eventBusBoxesOptions)
Parameters
Type Name Description
System.IServiceProvider serviceProvider
AbpAsyncTimer timer
IDistributedEventBus distributedEventBus
IAbpDistributedLock distributedLock
Microsoft.Extensions.Options.IOptions<TOptions><AbpEventBusBoxesOptions> eventBusBoxesOptions

Properties

DistributedEventBus

Declaration
protected IDistributedEventBus DistributedEventBus { get; }
Property Value
Type Description
IDistributedEventBus

DistributedLock

Declaration
protected IAbpDistributedLock DistributedLock { get; }
Property Value
Type Description
IAbpDistributedLock

DistributedLockName

Declaration
protected string DistributedLockName { get; }
Property Value
Type Description
string

EventBusBoxesOptions

Declaration
protected AbpEventBusBoxesOptions EventBusBoxesOptions { get; }
Property Value
Type Description
AbpEventBusBoxesOptions

Logger

Declaration
public ILogger<OutboxSender> Logger { get; set; }
Property Value
Type Description
Microsoft.Extensions.Logging.ILogger<TCategoryName><OutboxSender>

Outbox

Declaration
protected IEventOutbox Outbox { get; }
Property Value
Type Description
IEventOutbox

OutboxConfig

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

ServiceProvider

Declaration
protected IServiceProvider ServiceProvider { get; }
Property Value
Type Description
System.IServiceProvider

StoppingToken

Declaration
protected CancellationToken StoppingToken { get; }
Property Value
Type Description
System.Threading.CancellationToken

StoppingTokenSource

Declaration
protected CancellationTokenSource StoppingTokenSource { get; }
Property Value
Type Description
System.Threading.CancellationTokenSource

Timer

Declaration
protected AbpAsyncTimer Timer { get; }
Property Value
Type Description
AbpAsyncTimer

Methods

PublishOutgoingMessagesAsync(List<OutgoingEventInfo>)

Declaration
protected virtual Task PublishOutgoingMessagesAsync(List<OutgoingEventInfo> waitingEvents)
Parameters
Type Name Description
System.Collections.Generic.List<T><OutgoingEventInfo> waitingEvents
Returns
Type Description
System.Threading.Tasks.Task

PublishOutgoingMessagesInBatchAsync(List<OutgoingEventInfo>)

Declaration
protected virtual Task PublishOutgoingMessagesInBatchAsync(List<OutgoingEventInfo> waitingEvents)
Parameters
Type Name Description
System.Collections.Generic.List<T><OutgoingEventInfo> waitingEvents
Returns
Type Description
System.Threading.Tasks.Task

RunAsync()

Declaration
protected virtual Task RunAsync()
Returns
Type Description
System.Threading.Tasks.Task

StartAsync(OutboxConfig, CancellationToken)

Declaration
public virtual Task StartAsync(OutboxConfig outboxConfig, CancellationToken cancellationToken = default)
Parameters
Type Name Description
OutboxConfig outboxConfig
System.Threading.CancellationToken cancellationToken
Returns
Type Description
System.Threading.Tasks.Task

StopAsync(CancellationToken)

Declaration
public virtual Task StopAsync(CancellationToken cancellationToken = default)
Parameters
Type Name Description
System.Threading.CancellationToken cancellationToken
Returns
Type Description
System.Threading.Tasks.Task

Implements

Extension Methods