EventHubAdapterFactory 類別

定義

命名空間:

Orleans.ServiceBus.Providers

組件:

Orleans.Streaming.EventHubs.dll

套件:

Microsoft.Orleans.OrleansServiceBus v3.6.5

來源:

EventHubAdapterFactory.cs

佇列配接器處理站，可讓 PersistentStreamProvider 使用 EventHub 作為其後端持續性事件佇列。

public class EventHubAdapterFactory : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type EventHubAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class EventHubAdapterFactory
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

繼承

Object

EventHubAdapterFactory

衍生

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

實作

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

建構函式

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)

佇列配接器處理站，可讓 PersistentStreamProvider 使用 EventHub 作為其後端持續性事件佇列。

欄位

dataAdapter	資料配接器
EventHubReceiverFactory	建立 IEventHubReceiver 的 Factory
logger	啟用記錄
serviceProvider	架構服務提供者

屬性

CacheFactory	建立 eventhub 分割區的訊息快取。
Direction	此佇列配接器的方向：讀取、寫入或 ReadWrite。
IsRewindable	判斷這是否為可倒轉的資料流程配接器 - 支援從先前的時間點訂閱。
Name	配接器的名稱。 主要用於記錄用途
QueueMapperFactory	建立佇列對應程式以將 EventHub 分割區對應至佇列
ReceiverMonitorFactory	建立接收者監視器來報告效能計量。 Factory funciton 應該會傳回 IEventHubReceiverMonitor。
SerializationManager	取得序列化管理員。
StreamFailureHandlerFactory	建立分割區的失敗處理常式。

方法

Create(IServiceProvider, String)	佇列配接器處理站，可讓 PersistentStreamProvider 使用 EventHub 作為其後端持續性事件佇列。
CreateAdapter()	建立佇列配接器。
CreateCacheFactory(EventHubStreamCachePressureOptions)	建立 IEventHubQueueCacheFactory。 預設會建立 EventHubQueueCacheFactory。 使用者可以覆寫此函式，以傳回自己的 IEventHubQueueCacheFactory 實作，並視情況傳回 IEventHubQueueCacheFactory 的其他自訂。
CreateQueueCache(QueueId)	建立指定佇列識別碼的快取
CreateReceiver(QueueId)	建立特定 queueId 的 quere 接收者
GetDeliveryFailureHandler(QueueId)	佇列的 Aquire 傳遞失敗處理常式
GetPartitionIdsAsync()	從 eventhub 取得分割區識別碼
GetQueueAdapterCache()	建立佇列訊息快取配接器
GetStreamQueueMapper()	建立佇列對應程式
Init()	佇列配接器處理站，可讓 PersistentStreamProvider 使用 EventHub 作為其後端持續性事件佇列。
InitEventHubClient()	佇列配接器處理站，可讓 PersistentStreamProvider 使用 EventHub 作為其後端持續性事件佇列。
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	將一組事件寫入佇列，做為與所提供 streamId 相關聯的單一批次。

擴充方法

QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)

將一組事件寫入佇列，做為與所提供 streamId 相關聯的單一批次。