Class DbContextEventInbox<TDbContext>

Inheritance
object
DbContextEventInbox<TDbContext>
OracleDbContextEventInbox<TDbContext>
PostgreSqlDbContextEventInbox<TDbContext>
SqlRawDbContextEventInbox<TDbContext>
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.EntityFrameworkCore.DistributedEvents
Assembly: Volo.Abp.EntityFrameworkCore.dll
Syntax
public class DbContextEventInbox<TDbContext> : IDbContextEventInbox<TDbContext>, IEventInbox where TDbContext : IHasEventInbox
Type Parameters
Name Description
TDbContext

Constructors

DbContextEventInbox(IDbContextProvider<TDbContext>, IClock, IOptions<AbpEventBusBoxesOptions>)

Declaration
public DbContextEventInbox(IDbContextProvider<TDbContext> dbContextProvider, IClock clock, IOptions<AbpEventBusBoxesOptions> eventBusBoxesOptions)
Parameters
Type Name Description
IDbContextProvider<TDbContext> dbContextProvider
IClock clock
Microsoft.Extensions.Options.IOptions<TOptions><AbpEventBusBoxesOptions> eventBusBoxesOptions

Properties

Clock

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

DbContextProvider

Declaration
protected IDbContextProvider<TDbContext> DbContextProvider { get; }
Property Value
Type Description
IDbContextProvider<TDbContext>

EventBusBoxesOptions

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

Methods

DeleteOldEventsAsync()

Declaration
[UnitOfWork]
public virtual Task DeleteOldEventsAsync()
Returns
Type Description
System.Threading.Tasks.Task

EnqueueAsync(IncomingEventInfo)

Declaration
[UnitOfWork]
public virtual Task EnqueueAsync(IncomingEventInfo incomingEvent)
Parameters
Type Name Description
IncomingEventInfo incomingEvent
Returns
Type Description
System.Threading.Tasks.Task

ExistsByMessageIdAsync(string)

Declaration
[UnitOfWork]
public virtual Task<bool> ExistsByMessageIdAsync(string messageId)
Parameters
Type Name Description
string messageId
Returns
Type Description
System.Threading.Tasks.Task<TResult><bool>

GetWaitingEventsAsync(int, CancellationToken)

Declaration
[UnitOfWork]
public virtual 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
[UnitOfWork]
public virtual Task MarkAsProcessedAsync(Guid id)
Parameters
Type Name Description
System.Guid id
Returns
Type Description
System.Threading.Tasks.Task

Implements

Extension Methods