Class InboxProcessor

Inheritance

object

InboxProcessor

Implements

IInboxProcessor

ITransientDependency

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
IServiceProvider	serviceProvider
AbpAsyncTimer	timer
IDistributedEventBus	distributedEventBus
IAbpDistributedLock	distributedLock
IUnitOfWorkManager	unitOfWorkManager
IClock	clock
IOptions<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
DateTime?

Logger

Declaration

public ILogger<InboxProcessor> Logger { get; set; }

Property Value

Type	Description
ILogger<InboxProcessor>

ServiceProvider

Declaration

protected IServiceProvider ServiceProvider { get; }

Property Value

Type	Description
IServiceProvider

StoppingToken

Declaration

protected CancellationToken StoppingToken { get; }

Property Value

Type	Description
CancellationToken

StoppingTokenSource

Declaration

protected CancellationTokenSource StoppingTokenSource { get; }

Property Value

Type	Description
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
Task

RunAsync()

Declaration

protected virtual Task RunAsync()

Returns

Type	Description
Task

StartAsync(InboxConfig, CancellationToken)

Declaration

public Task StartAsync(InboxConfig inboxConfig, CancellationToken cancellationToken = default)

Parameters

Type	Name	Description
InboxConfig	inboxConfig
CancellationToken	cancellationToken

Returns

Type	Description
Task

StopAsync(CancellationToken)

Declaration

public Task StopAsync(CancellationToken cancellationToken = default)

Parameters

Type	Name	Description
CancellationToken	cancellationToken

Returns

Type	Description
Task

Implements

IInboxProcessor

ITransientDependency

Extension Methods

AbpObjectExtensions.As<T>(object)

AbpObjectExtensions.To<T>(object)

LockExtensions.Locking(object, Action)

LockExtensions.Locking<TResult>(object, Func<TResult>)

AbpObjectExtensions.If<T>(T, bool, Action<T>)

AbpObjectExtensions.If<T>(T, bool, Func<T, T>)

AbpObjectExtensions.IsIn<T>(T, IEnumerable<T>)

AbpObjectExtensions.IsIn<T>(T, params T[])

AbpQueryableExtensions.OrderByIf<T, TQueryable>(TQueryable, bool, string)

AbpQueryableExtensions.PageBy<T, TQueryable>(TQueryable, int, int)

AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, bool>>)

AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, int, bool>>)

AbpOpenIddictQueryableExtensions.SkipIf<T, TQueryable>(TQueryable, bool, int?)

AbpOpenIddictQueryableExtensions.TakeIf<T, TQueryable>(TQueryable, bool, int?)

LockExtensions.Locking<T>(T, Action<T>)

LockExtensions.Locking<T, TResult>(T, Func<T, TResult>)