Interface IEventInbox

Namespace: Volo.Abp.EventBus.Distributed

Assembly: Volo.Abp.EventBus.Abstractions.dll

Syntax

public interface IEventInbox

Methods

DeleteOldEventsAsync()

Declaration

Task DeleteOldEventsAsync()

Returns

Type	Description
Task

EnqueueAsync(IncomingEventInfo)

Declaration

Task EnqueueAsync(IncomingEventInfo incomingEvent)

Parameters

Type	Name	Description
IncomingEventInfo	incomingEvent

Returns

Type	Description
Task

ExistsByMessageIdAsync(string)

Declaration

Task<bool> ExistsByMessageIdAsync(string messageId)

Parameters

Type	Name	Description
string	messageId

Returns

Type	Description
Task<bool>

GetWaitingEventsAsync(int, CancellationToken)

Declaration

Task<List<IncomingEventInfo>> GetWaitingEventsAsync(int maxCount, CancellationToken cancellationToken = default)

Parameters

Type	Name	Description
int	maxCount
CancellationToken	cancellationToken

Returns

Type	Description
Task<List<IncomingEventInfo>>

MarkAsProcessedAsync(Guid)

Declaration

Task MarkAsProcessedAsync(Guid id)

Parameters

Type	Name	Description
Guid	id

Returns

Type	Description
Task

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