EventHubAdapterFactory

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. EventHubAdapterFactory

class

Namespace: Orleans.Streaming.EventHubs

NuGetSourceMarkdown

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

public class EventHubAdapterFactory : IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Constructors

• EventHubAdapterFactory(string, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IEnvironmentStatisticsProvider)

Properties

• Direction Direction of this queue adapter: Read, Write or ReadWrite.
• IsRewindable Determines whether this is a rewindable stream adapter - supports subscribing from previous point in time.
• Name Name of the adapter. Primarily for logging purposes

Methods

• Create(IServiceProvider, string)
• CreateAdapter Create queue adapter.
• CreateQueueCache(QueueId) Create a cache for a given queue id
• CreateReceiver(QueueId) Creates a queue receiver for the specified queueId
• GetDeliveryFailureHandler(QueueId) Acquire delivery failure handler for a queue
• GetQueueAdapterCache Create queue message cache adapter
• GetStreamQueueMapper Create queue mapper
• Init
• QueueMessageBatchAsync(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<string, object>) Writes a set of events to the queue as a single batch associated with the provided streamId.