Class InboxProcessor

Inheritance
object
InboxProcessor
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 InboxProcessor : IInboxProcessor, ITransientDependency

Constructors

InboxProcessor(IServiceProvider, AbpAsyncTimer, IDistributedEventBus, IAbpDistributedLock, IUnitOfWorkManager, IClock, IOptions<AbpEventBusBoxesOptions>)

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

Properties

Clock

Declaration
protected IClock Clock { get; }
Property Value
Type Description
IClock

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

Inbox

Declaration
protected IEventInbox Inbox { get; }
Property Value
Type Description
IEventInbox

InboxConfig

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

LastCleanTime

Declaration
protected DateTime? LastCleanTime { get; set; }
Property Value
Type Description
System.DateTime?

Logger

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

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

UnitOfWorkManager

Declaration
protected IUnitOfWorkManager UnitOfWorkManager { get; }
Property Value
Type Description
IUnitOfWorkManager

Methods

DeleteOldEventsAsync()

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

RunAsync()

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

StartAsync(InboxConfig, CancellationToken)

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

StopAsync(CancellationToken)

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

Implements

Extension Methods