Class EventHubExceptionReceiver

inherit this class and override it's methods in order to receive event hub exceptions.

Inheritance

object

EventHubExceptionReceiver

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: FastEndpoints

Assembly: FastEndpoints.Messaging.Remote.dll

Syntax

public abstract class EventHubExceptionReceiver

Methods

OnGetNextEventRecordError<TEvent>(string, int, Exception, CancellationToken)

this method is triggered when the storage provider has trouble retrieving the next event record.

Declaration

public virtual Task OnGetNextEventRecordError<TEvent>(string subscriberID, int attemptCount, Exception exception, CancellationToken ct) where TEvent : class, IEvent

Parameters

Type	Name	Description
string	subscriberID	the unique ID of the subscriber
int	attemptCount	the number of times the record was attempted to be retrieved
Exception	exception	the actual exception that was thrown by the operation
CancellationToken	ct	cancellation token

Returns

Type	Description
Task

Type Parameters

Name	Description
TEvent	the type of the event

OnInMemoryQueueOverflow<TEvent>(IEventStorageRecord, CancellationToken)

this method is triggered when the default in-memory storage provider's internal queue for the given event type has been stagnant and in an overflow state.

Declaration

public virtual Task OnInMemoryQueueOverflow<TEvent>(IEventStorageRecord record, CancellationToken ct) where TEvent : class, IEvent

Parameters

Type	Name	Description
IEventStorageRecord	record	the event storage record that was supposed to be added to the queue
CancellationToken	ct	cancellation token

Returns

Type	Description
Task

Type Parameters

Name	Description
TEvent	the type of the event

OnMarkEventAsCompleteError<TEvent>(IEventStorageRecord, int, Exception, CancellationToken)

this method is triggered when the storage provider has trouble marking an event record as complete.

Declaration

public virtual Task OnMarkEventAsCompleteError<TEvent>(IEventStorageRecord record, int attemptCount, Exception exception, CancellationToken ct) where TEvent : class, IEvent

Parameters

Type	Name	Description
IEventStorageRecord	record	the event storage record that was supposed to be marked complete
int	attemptCount	the number of times the record was attempted to be marked complete
Exception	exception	the actual exception that was thrown by the operation
CancellationToken	ct	cancellation token

Returns

Type	Description
Task

Type Parameters

Name	Description
TEvent	the type of the event

OnStoreEventRecordError<TEvent>(IEventStorageRecord, int, Exception, CancellationToken)

this method is triggered when the storage provider has trouble persisting an event record.

Declaration

public virtual Task OnStoreEventRecordError<TEvent>(IEventStorageRecord record, int attemptCount, Exception exception, CancellationToken ct) where TEvent : class, IEvent

Parameters

Type	Name	Description
IEventStorageRecord	record	the event storage record that was supposed to be persisted
int	attemptCount	the number of times the record was attempted to be persisted
Exception	exception	the actual exception that was thrown by the operation
CancellationToken	ct	cancellation token

Returns

Type	Description
Task

Type Parameters

Name	Description
TEvent	the type of the event