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.

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

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()

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>