IMessageSession インターフェイス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
Session オブジェクトについて説明します。 IMessageSession を使用して、セッションに対する操作を実行できます。
public interface IMessageSession : Microsoft.Azure.ServiceBus.Core.IMessageReceivertype IMessageSession = interface
interface IMessageReceiver
interface IReceiverClient
interface IClientEntityPublic Interface IMessageSession
Implements IMessageReceiver- 実装
注釈
AMQP 1.0 プロトコルの "グループ" とも呼ばれる Service Bus セッションは、関連するメッセージの無制限シーケンスです。 ServiceBus では、セッション内のメッセージの順序が保証されます。
メッセージのプロパティをアプリケーション定義の一意識別子に設定 SessionId することで、メッセージをトピックまたはキューに送信するときに、すべての送信者がセッションを作成できます。 AMQP 1.0 プロトコル レベルでは、この値は group-id プロパティに相当します。
キューまたはトピック サブスクリプションにセッションの SessionId を含むメッセージが少なくとも 1 つあると、セッションが存在します。 セッションが存在すると、セッションの有効期限が切れたり消えたりするタイミングやジェスチャは定義されません。
プロパティ
| ClientId |
このクライアントを識別する ID を取得します。 これは、ログと例外を関連付けるために使用できます。 (継承元 IClientEntity) |
| IsClosedOrClosing |
クライアントが閉じているか閉じている場合は true を返します。 (継承元 IClientEntity) |
| LastPeekedSequenceNumber |
最後にピークされたメッセージのシーケンス番号を取得します。 (継承元 IMessageReceiver) |
| LockedUntilUtc |
によって識別されたセッションがこのクライアントに対して SessionId ロックされるまでの時間を取得します。 |
| OperationTimeout |
個々の操作がタイムアウトする期間。 (継承元 IClientEntity) |
| OwnsConnection |
接続が所有されている場合は true、接続が共有されている場合は false を返します。 (継承元 IClientEntity) |
| Path |
エンティティ パスを取得します。 (継承元 IClientEntity) |
| PrefetchCount |
プリフェッチは、アプリケーションが Receive を使用してメッセージを要求する前に、ローカル取得のためにメッセージをすぐに使用できるようにすることで、メッセージ フローを高速化します。 0 以外の値を設定すると、メッセージのプリフェッチ数がプリフェッチされます。 値を 0 に設定すると、プリフェッチがオフになります。 既定値は 0 です。 (継承元 IReceiverClient) |
| ReceiveMode |
ReceiveMode現在のレシーバーの を取得します。 (継承元 IReceiverClient) |
| RegisteredPlugins |
このクライアントの現在登録されているプラグインの一覧を取得します。 (継承元 IClientEntity) |
| ServiceBusConnection |
Service Bus 名前空間への接続オブジェクト。 (継承元 IClientEntity) |
| SessionId |
SessionId を取得します。 |
メソッド
| AbandonAsync(String, IDictionary<String,Object>) |
ロック トークンを使用して を Message 破棄します。 これにより、メッセージを再び処理できるようになります。 (継承元 IReceiverClient) |
| CloseAsync() |
クライアントを閉じます。 その接続によって開かれた接続を閉じます。 (継承元 IClientEntity) |
| CompleteAsync(IEnumerable<String>) |
ロック トークンの Message 一覧を使用して一連のを完了します。 これにより、サービスからメッセージが削除されます。 (継承元 IMessageReceiver) |
| CompleteAsync(String) |
ロック トークンを使用して を Message 完了します。 これにより、キューからメッセージが削除されます。 (継承元 IReceiverClient) |
| DeadLetterAsync(String, IDictionary<String,Object>) |
メッセージを配信不能サブキューに移動します。 (継承元 IReceiverClient) |
| DeadLetterAsync(String, String, String) |
メッセージを配信不能サブキューに移動します。 (継承元 IReceiverClient) |
| DeferAsync(String, IDictionary<String,Object>) |
受信側がメッセージの処理を延期することを示します。 (継承元 IMessageReceiver) |
| GetStateAsync() |
セッションの状態を取得します。 |
| PeekAsync() |
受信側またはメッセージ・ソースの状態を変更せずに、次のアクティブ・メッセージをフェッチします。 (継承元 IMessageReceiver) |
| PeekAsync(Int32) |
受信側またはメッセージ・ソースの状態を変更せずに、アクティブ・メッセージの次のバッチをフェッチします。 (継承元 IMessageReceiver) |
| PeekBySequenceNumberAsync(Int64) |
受信側またはメッセージ ソースの状態を変更せずに、次のメッセージを非同期に読み取ります。 (継承元 IMessageReceiver) |
| PeekBySequenceNumberAsync(Int64, Int32) |
メッセージのバッチをピークします。 (継承元 IMessageReceiver) |
| ReceiveAsync() |
モードを使用して定義されたエンティティからメッセージをPathReceiveMode受信します。 (継承元 IMessageReceiver) |
| ReceiveAsync(Int32) |
モードを使用してPath定義されたエンティティから最大メッセージ |
| ReceiveAsync(Int32, TimeSpan) |
モードを使用してPath定義されたエンティティから最大メッセージ |
| ReceiveAsync(TimeSpan) |
モードを使用して定義されたエンティティからメッセージをPathReceiveMode受信します。 (継承元 IMessageReceiver) |
| ReceiveDeferredMessageAsync(IEnumerable<Int64>) |
IList<T>によって |
| ReceiveDeferredMessageAsync(Int64) |
によって |
| RegisterMessageHandler(Func<Message,CancellationToken,Task>, Func<ExceptionReceivedEventArgs,Task>) |
エンティティからメッセージを継続的に受信します。 メッセージ ハンドラーを登録し、メッセージを受信する新しいスレッドを開始します。 このハンドラー(Func<T1,T2,TResult>) は、受信者が新しいメッセージを受信するたびに待機されます。 (継承元 IReceiverClient) |
| RegisterMessageHandler(Func<Message,CancellationToken,Task>, MessageHandlerOptions) |
エンティティからメッセージを継続的に受信します。 メッセージ ハンドラーを登録し、メッセージを受信する新しいスレッドを開始します。 このハンドラー(Func<T1,T2,TResult>) は、受信者が新しいメッセージを受信するたびに待機されます。 (継承元 IReceiverClient) |
| RegisterPlugin(ServiceBusPlugin) |
ServiceBusPluginこのクライアントで使用する を登録します。 (継承元 IClientEntity) |
| RenewLockAsync(Message) |
メッセージのロックを更新します。 ロックは、キューで指定された設定に基づいて更新されます。 (継承元 IMessageReceiver) |
| RenewLockAsync(String) |
メッセージのロックを更新します。 ロックは、キューで指定された設定に基づいて更新されます。 新しいロック トークンの有効期限の日付と時刻 (UTC 形式)。 (継承元 IMessageReceiver) |
| RenewSessionLockAsync() |
で指定されたセッションのロックを更新します SessionId。 ロックは、エンティティで指定された設定に基づいて更新されます。 |
| SetStateAsync(Byte[]) |
後でを使用して取得できるセッションでカスタム状態を設定する GetStateAsync() |
| UnregisterMessageHandlerAsync(TimeSpan) |
アクティブなメッセージ ハンドラーが登録されている場合は、受信側からメッセージ ハンドラーの登録を解除します。 この操作は、未完了の受信操作とメッセージ処理操作の完了を待機し、以前に登録したメッセージ ハンドラーで将来の受信を登録解除します。 (継承元 IReceiverClient) |
| UnregisterPlugin(String) |
の登録を ServiceBusPlugin解除します。 (継承元 IClientEntity) |
適用対象
Azure SDK for .NET