EventHubConsumerGroup クラス

リファレンス

定義

名前空間:: Microsoft.ServiceBus.Messaging

アセンブリ:: Microsoft.ServiceBus.dll

パッケージ:: WindowsAzure.ServiceBus v6.2.2

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。

public sealed class EventHubConsumerGroup : Microsoft.ServiceBus.Messaging.ClientEntity

type EventHubConsumerGroup = class
    inherit ClientEntity

Public NotInheritable Class EventHubConsumerGroup
Inherits ClientEntity

継承: Object

ClientEntity
EventHubConsumerGroup

フィールド

DefaultGroupName	EventHub の作成時に事前に作成される既定の ConsumerGroup の名前。
EndOfStream	ストリームの末尾を示す定数。これは、レシーバーの作成時にオフセット引数として使用して、特定の時点/オフセット値ではなく、最新のイベントからの受信を開始できます。
StartOfStream	ストリームの開始を示す定数。これは、レシーバーの作成時にオフセット引数として使用できます。

プロパティ

EnableReceiverRuntimeMetric	レシーバーのランタイムメトリックが有効かどうかを示す値を取得または設定します。
EventHubPath	イベントハブのパスを取得します。
GroupName	コンシューマーグループの名前を取得します。
IsClosed	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
PrefetchCount	受信操作でアクティブにキャッシュされるイベントの数を取得または設定します。既定では、この値はから EventHubClient継承されます。既定値は 10,000 です。
PrefetchSizeInBytes	受信操作がアクティブにキャッシュする合計サイズ (バイト単位) を取得または設定します。各イベントデータのサイズは、プロパティによって SerializedSizeInBytes 決まります。
RetryPolicy	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
ThisLock	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)

メソッド

Abort()	メッセージングエンティティに対して中止機能を実行します。 (継承元 ClientEntity)
Close()	クリーンアップメッセージを Service Bus に送信して、エンティティの使用の完了を通知します。 (継承元 ClientEntity)
CloseAsync()	クリーンアップメッセージを Service Bus に非同期的に送信して、エンティティの使用の完了を通知します。 (継承元 ClientEntity)
CreateReceiver(String, DateTime, Int64, ReceiverOptions)	指定した日付と時刻から始まる、指定したパーティションに新しい Event Hubs レシーバーを作成します。作成したレシーバーを使用して、で指定された 1 つの Event Hubs パーティションのイベントを `partitionId`受信できます。
CreateReceiver(String, DateTime, ReceiverOptions)	指定した日付と時刻から始まる、指定したパーティションに新しい Event Hubs レシーバーを作成します。作成したレシーバーを使用して、で指定された 1 つの Event Hubs パーティションのイベントを `partitionId`受信できます。
CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions)	指定したパーティション内の、指定した開始位置に新しい Event Hubs レシーバーを作成します。作成したレシーバーを使用して、で指定された 1 つの Event Hubs パーティションのイベントを `partitionId`受信できます。
CreateReceiver(String, Int64, ReceiverOptions)	指定したパーティションと指定したエポック値に新しい Event Hubs レシーバーを作成します。作成したレシーバーを使用して、で指定された 1 つの Event Hubs パーティションのイベントを `partitionId`受信できます。
CreateReceiver(String, ReceiverOptions)	指定したパーティションに新しい Event Hubs レシーバーを作成します。作成したレシーバーを使用して、で指定された 1 つの Event Hubs パーティションのイベントを `partitionId`受信できます。
CreateReceiver(String, String, Boolean, Int64, ReceiverOptions)	指定した開始オフセットで、指定したパーティションに新しい Event Hubs レシーバーを作成します。作成したレシーバーを使用して、で指定された 1 つの Event Hubs パーティションのイベントを `partitionId`受信できます。
CreateReceiver(String, String, Boolean, ReceiverOptions)	指定した開始オフセットで、指定したパーティションに新しい Event Hubs レシーバーを作成します。作成したレシーバーを使用して、で指定された 1 つの Event Hubs パーティションのイベントを `partitionId`受信できます。
CreateReceiver(String, String, Int64, ReceiverOptions)	指定した開始オフセットで、指定したパーティションに新しい Event Hubs レシーバーを作成します。
CreateReceiver(String, String, ReceiverOptions)	指定した開始オフセットで、指定したパーティションに新しい Event Hubs レシーバーを作成します。作成したレシーバーを使用して、で指定された 1 つの Event Hubs パーティションのイベントを `partitionId`受信できます。
CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)	CreateReceiver(String, DateTime, Int64, ReceiverOptions) の非同期バージョン。
CreateReceiverAsync(String, DateTime, ReceiverOptions)	CreateReceiver(String, DateTime, ReceiverOptions) の非同期バージョン。
CreateReceiverAsync(String, EventPosition, Nullable<Int64>, ReceiverOptions)	CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions) の非同期バージョン。
CreateReceiverAsync(String, Int64, ReceiverOptions)	CreateReceiver(String, Int64, ReceiverOptions) の非同期バージョン。
CreateReceiverAsync(String, ReceiverOptions)	CreateReceiver(String, ReceiverOptions) の非同期バージョン。
CreateReceiverAsync(String, String, Boolean, Int64, ReceiverOptions)	CreateReceiver(String, String, Boolean, Int64, ReceiverOptions) の非同期バージョン。
CreateReceiverAsync(String, String, Boolean, ReceiverOptions)	CreateReceiver(String, String, Boolean, ReceiverOptions) の非同期バージョン。
CreateReceiverAsync(String, String, Int64, ReceiverOptions)	CreateReceiver(String, String, Int64, ReceiverOptions) の非同期バージョン。
CreateReceiverAsync(String, String, ReceiverOptions)	CreateReceiver(String, ReceiverOptions) の非同期バージョン。
Fault()	内部使用専用です。このクラスから継承しないでください。 (継承元 ClientEntity)
OnAbort()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnBeginClose(TimeSpan, AsyncCallback, Object)	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnBeginOpen(TimeSpan, AsyncCallback, Object)	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnClose(TimeSpan)	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnClosed()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnEndClose(IAsyncResult)	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnEndOpen(IAsyncResult)	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnFaulted()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnOpen(TimeSpan)	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
OnOpened()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
RegisterProcessor<T>(Lease, ICheckpointManager)	から指定した PartitionId に対して Event Hubs からのイベントの使用を開始するために、の実装IEventProcessorを登録しますOffset。このオーバーロードを使用して、のカスタム実装 ICheckpointManagerを使用してメッセージオフセットをチェックポイント処理するイベントプロセッサを作成します。
RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)	から指定した PartitionId に対して Event Hubs からのイベントの使用を開始するために、の実装IEventProcessorを登録しますOffset。このオーバーロードを使用して、のカスタム実装 ICheckpointManagerを使用してメッセージオフセットをチェックポイント処理するイベントプロセッサを作成します。
RegisterProcessorAsync<T>(Lease, ICheckpointManager)	RegisterProcessor<T>(Lease, ICheckpointManager) の非同期バージョン。
RegisterProcessorAsync<T>(Lease, ICheckpointManager, EventProcessorOptions)	RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions) の非同期バージョン。
RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory)	IEventProcessorFactoryでPartitionId指定されたパーティションのIEventProcessorイベントの使用を開始するために、のインスタンスの作成に使用されるオブジェクトを Offsetから登録します。このオーバーロードを使用して、のカスタム実装 ICheckpointManagerを使用してメッセージオフセットをチェックポイント処理するイベントプロセッサを作成します。
RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)	IEventProcessorFactoryでPartitionId指定されたパーティションのIEventProcessorイベントの使用を開始するために、のインスタンスの作成に使用されるオブジェクトを Offsetから登録します。このオーバーロードを使用して、のカスタム実装 ICheckpointManagerを使用してメッセージオフセットをチェックポイント処理するイベントプロセッサを作成します。
RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory)	RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory) の非同期バージョン。
RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)	RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions) の非同期バージョン。
ThrowIfClosed()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
ThrowIfDisposed()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
ThrowIfDisposedOrImmutable()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
ThrowIfDisposedOrNotOpen()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
ThrowIfFaulted()	イベントハブ内のコンシューマーグループを表します。このクラスは、イベントハブ内の特定のコンシューマーグループのレシーバーを作成します。既定のコンシューマーグループまたは別のユーザーが作成したコンシューマーグループを指定できます。 (継承元 ClientEntity)
UnregisterProcessor(Lease, CloseReason)	IEventProcessorでPartitionId指定されたパーティションの登録を解除します。これにより、 CloseAsync(PartitionContext, CloseReason) 基になるイベントプロセッサでが呼び出されます。
UnregisterProcessorAsync(Lease, CloseReason)	UnregisterProcessor(Lease, CloseReason) の非同期バージョン。

イベント

EventProcessorLifeCycleManagerFaulted

適用対象

次の方法で共有