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
System.Threading.Tasks.Task

EnqueueAsync(IncomingEventInfo)

Declaration

Task EnqueueAsync(IncomingEventInfo incomingEvent)

Parameters

Type	Name	Description
IncomingEventInfo	incomingEvent

Returns

Type	Description
System.Threading.Tasks.Task

ExistsByMessageIdAsync(string)

Declaration

Task<bool> ExistsByMessageIdAsync(string messageId)

Parameters

Type	Name	Description
string	messageId

Returns

Type	Description
System.Threading.Tasks.Task<TResult><bool>

GetWaitingEventsAsync(int, CancellationToken)

Declaration

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

Parameters

Type	Name	Description
int	maxCount
System.Threading.CancellationToken	cancellationToken

Returns

Type	Description
System.Threading.Tasks.Task<TResult><System.Collections.Generic.List<T><IncomingEventInfo>>

MarkAsProcessedAsync(Guid)

Declaration

Task MarkAsProcessedAsync(Guid id)

Parameters

Type	Name	Description
System.Guid	id

Returns

Type	Description
System.Threading.Tasks.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>>)

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

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