Class DbContextEventOutbox<TDbContext>
Inheritance
object
DbContextEventOutbox<TDbContext>
Inherited Members
object.GetType()
object.MemberwiseClone()
object.ToString()
object.Equals(object)
object.Equals(object, object)
object.ReferenceEquals(object, object)
object.GetHashCode()
Assembly: Volo.Abp.EntityFrameworkCore.dll
Syntax
public class DbContextEventOutbox<TDbContext> : IDbContextEventOutbox<TDbContext>, IEventOutbox where TDbContext : IHasEventOutbox
Type Parameters
| Name |
Description |
| TDbContext |
|
Constructors
DbContextEventOutbox(IDbContextProvider<TDbContext>)
Declaration
public DbContextEventOutbox(IDbContextProvider<TDbContext> dbContextProvider)
Parameters
Properties
DbContextProvider
Declaration
protected IDbContextProvider<TDbContext> DbContextProvider { get; }
Property Value
Methods
DeleteAsync(Guid)
Declaration
[UnitOfWork]
public virtual Task DeleteAsync(Guid id)
Parameters
| Type |
Name |
Description |
| System.Guid |
id |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task |
|
DeleteManyAsync(IEnumerable<Guid>)
Declaration
[UnitOfWork]
public virtual Task DeleteManyAsync(IEnumerable<Guid> ids)
Parameters
| Type |
Name |
Description |
| System.Collections.Generic.IEnumerable<T><System.Guid> |
ids |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task |
|
EnqueueAsync(OutgoingEventInfo)
Declaration
[UnitOfWork]
public virtual Task EnqueueAsync(OutgoingEventInfo outgoingEvent)
Parameters
Returns
| Type |
Description |
| System.Threading.Tasks.Task |
|
GetWaitingEventsAsync(int, CancellationToken)
Declaration
[UnitOfWork]
public virtual Task<List<OutgoingEventInfo>> 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><OutgoingEventInfo>> |
|
Implements
Extension Methods