EventHubAdapterFactory Methods

Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.

Create(IServiceProvider, string)

static

public static EventHubAdapterFactory Create(IServiceProvider services, string name)

Parameters

servicesIServiceProvider
namestring

CreateAdapter

View source

public Task<IQueueAdapter> CreateAdapter()

Create queue adapter.

CreateCacheFactory(EventHubStreamCachePressureOptions)

virtual

View source

protected virtual IEventHubQueueCacheFactory CreateCacheFactory(EventHubStreamCachePressureOptions eventHubCacheOptions)

Create a IEventHubQueueCacheFactory. It will create a EventHubQueueCacheFactory by default. User can override this function to return their own implementation of IEventHubQueueCacheFactory, and other customization of IEventHubQueueCacheFactory if they may.

Parameters

eventHubCacheOptionsEventHubStreamCachePressureOptions

CreateQueueCache(QueueId)

View source

public IQueueCache CreateQueueCache(QueueId queueId)

Create a cache for a given queue id

Parameters

queueIdQueueId

CreateReceiver(QueueId)

View source

public IQueueAdapterReceiver CreateReceiver(QueueId queueId)

Creates a queue receiver for the specified queueId

Parameters

queueIdQueueId

GetDeliveryFailureHandler(QueueId)

View source

public Task<IStreamFailureHandler> GetDeliveryFailureHandler(QueueId queueId)

Acquire delivery failure handler for a queue

Parameters

queueIdQueueId

GetPartitionIdsAsync

virtual

View source

protected virtual Task<string[]> GetPartitionIdsAsync()

Get partition Ids from eventhub

GetQueueAdapterCache

View source

public IQueueAdapterCache GetQueueAdapterCache()

Create queue message cache adapter

GetStreamQueueMapper

View source

public IStreamQueueMapper GetStreamQueueMapper()

Create queue mapper

Init

virtual

View source

public virtual void Init()

InitEventHubClient

virtual

View source

protected virtual void InitEventHubClient()

QueueMessageBatchAsync(StreamId, IEnumerable<T>, StreamSequenceToken?, Dictionary<string, object>)

virtual

View source

public virtual Task QueueMessageBatchAsync<T>(StreamId streamId, IEnumerable<T> events, StreamSequenceToken? token, Dictionary<string, object>? requestContext)

Writes a set of events to the queue as a single batch associated with the provided streamId.

Parameters

streamIdStreamId
eventsIEnumerable<T>
tokenStreamSequenceToken?
requestContextDictionary<string, object>