Show / Hide Table of Contents

Class IncomingEventRecord

Inheritance
object
Entity
Entity<Guid>
BasicAggregateRoot<Guid>
IncomingEventRecord
Implements
IAggregateRoot<Guid>
IEntity<Guid>
IAggregateRoot
IEntity
IGeneratesDomainEvents
IHasExtraProperties
IHasCreationTime
Inherited Members
BasicAggregateRoot<Guid>.GetLocalEvents()
BasicAggregateRoot<Guid>.GetDistributedEvents()
BasicAggregateRoot<Guid>.ClearLocalEvents()
BasicAggregateRoot<Guid>.ClearDistributedEvents()
BasicAggregateRoot<Guid>.AddLocalEvent(object)
BasicAggregateRoot<Guid>.AddDistributedEvent(object)
Entity<Guid>.GetKeys()
Entity<Guid>.ToString()
Entity<Guid>.Id
Entity.EntityEquals(IEntity)
object.GetType()
object.MemberwiseClone()
object.Equals(object)
object.Equals(object, object)
object.ReferenceEquals(object, object)
object.GetHashCode()
Namespace: Volo.Abp.MongoDB.DistributedEvents
Assembly: Volo.Abp.MongoDB.dll
Syntax
public class IncomingEventRecord : BasicAggregateRoot<Guid>, IAggregateRoot<Guid>, IEntity<Guid>, IAggregateRoot, IEntity, IGeneratesDomainEvents, IHasExtraProperties, IHasCreationTime

Constructors

IncomingEventRecord()

Declaration
protected IncomingEventRecord()

IncomingEventRecord(IncomingEventInfo)

Declaration
public IncomingEventRecord(IncomingEventInfo eventInfo)
Parameters
Type Name Description
IncomingEventInfo eventInfo

Properties

CreationTime

Declaration
public DateTime CreationTime { get; }
Property Value
Type Description
DateTime

EventData

Declaration
public byte[] EventData { get; }
Property Value
Type Description
byte[]

EventName

Declaration
public string EventName { get; }
Property Value
Type Description
string

ExtraProperties

Declaration
public ExtraPropertyDictionary ExtraProperties { get; }
Property Value
Type Description
ExtraPropertyDictionary

HandledTime

Declaration
public DateTime? HandledTime { get; set; }
Property Value
Type Description
DateTime?

MaxEventNameLength

Declaration
public static int MaxEventNameLength { get; set; }
Property Value
Type Description
int

MessageId

Declaration
public string MessageId { get; }
Property Value
Type Description
string

NextRetryTime

Declaration
public DateTime? NextRetryTime { get; set; }
Property Value
Type Description
DateTime?

RetryCount

Declaration
public int RetryCount { get; set; }
Property Value
Type Description
int

Status

Declaration
public IncomingEventStatus Status { get; set; }
Property Value
Type Description
IncomingEventStatus

Methods

MarkAsDiscarded(DateTime)

Declaration
public void MarkAsDiscarded(DateTime discardedTime)
Parameters
Type Name Description
DateTime discardedTime

MarkAsProcessed(DateTime)

Declaration
public void MarkAsProcessed(DateTime processedTime)
Parameters
Type Name Description
DateTime processedTime

RetryLater(int, DateTime)

Declaration
public void RetryLater(int retryCount, DateTime nextRetryTime)
Parameters
Type Name Description
int retryCount
DateTime nextRetryTime

ToIncomingEventInfo()

Declaration
public IncomingEventInfo ToIncomingEventInfo()
Returns
Type Description
IncomingEventInfo

Implements

IAggregateRoot<TKey>
IEntity<TKey>
IAggregateRoot
IEntity
IGeneratesDomainEvents
IHasExtraProperties
IHasCreationTime

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>)
In this article
Back to top Powered by ABP.IO Platform