AzureTableStorageStreamFailureHandler<TEntity> Class

Definition

Namespace:

Orleans.Providers.Streams.PersistentStreams

Assembly:

Orleans.Streaming.AzureStorage.dll

Package:

Microsoft.Orleans.Streaming.AzureStorage v8.1.0

Source:

AzureTableStorageStreamFailureHandler.cs

Delivery failure handler that writes failures to azure table storage.

public class AzureTableStorageStreamFailureHandler<TEntity> : Orleans.Streams.IStreamFailureHandler where TEntity : StreamDeliveryFailureEntity, new()

type AzureTableStorageStreamFailureHandler<'Entity (requires 'Entity :> StreamDeliveryFailureEntity and 'Entity : (new : unit -> 'Entity))> = class
    interface IStreamFailureHandler

Public Class AzureTableStorageStreamFailureHandler(Of TEntity)
Implements IStreamFailureHandler

Type Parameters

TEntity

Inheritance

Object

AzureTableStorageStreamFailureHandler<TEntity>

Implements

IStreamFailureHandler

Constructors

AzureTableStorageStreamFailureHandler<TEntity>(Serializer<StreamSequenceToken>, ILoggerFactory, Boolean, String, AzureStorageOperationOptions, Func<TEntity>)

Delivery failure handler that writes failures to azure table storage.

Properties

ShouldFaultSubsriptionOnError

Indicates if the subscription should be put in a faulted state upon stream failures

Methods

InitAsync()	Initialization
OnDeliveryFailure(GuidId, String, StreamId, StreamSequenceToken)	Should be called when an event could not be delivered to a consumer, after exhausting retry attempts.
OnSubscriptionFailure(GuidId, String, StreamId, StreamSequenceToken)	Should be called when a subscription requested by a consumer could not be setup, after exhausting retry attempts.