CommunicationClientFactory<TCommunicationClient> インターフェイス

  • リファレンス
パッケージ:
microsoft.servicefabric.services.communication.client

型パラメーター

TCommunicationClient

public interface CommunicationClientFactory

通信クライアントが Service Fabric サービスと通信するためのファクトリを提供するために実装する必要があるインターフェイスを定義します。

メソッドの概要

修飾子と型 メソッドと説明
CompletableFuture<TCommunicationClient> getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

1 つ以上の通信リスナーを含む指定されたサービスのパーティションを再解決し、指定された listenerName に対応するエンドポイントと通信するクライアントを返します。 サービスのエンドポイントは、{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} の形式です。
CompletableFuture<TCommunicationClient> getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

1 つ以上の通信リスナーを含む指定されたサービスのパーティションを解決し、指定された listenerName に対応するエンドポイントと通信するクライアントを返します。 サービスのエンドポイントは、{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} の形式です。
CompletableFuture<OperationRetryControl> reportOperationExceptionAsync(TCommunicationClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

サービスにメッセージを送信するときに CommunicationClient で発生する例外を処理します

メソッドの詳細

getClientAsync

public CompletableFuture getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

1 つ以上の通信リスナーを含む指定されたサービスのパーティションを再解決し、指定された listenerName に対応するエンドポイントと通信するクライアントを返します。 サービスのエンドポイントは、{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} の形式です。

パラメーター:

previousRsp - 以前の ResolvedServicePartition 値
targetReplicaSelector - パーティション キーによって識別されるパーティション内のどのレプリカにクライアントが接続するかを指定します。
listenerName - クライアントが接続する必要がある、選択したレプリカのエンドポイント内のリスナーを指定します
retrySettings - クライアントの作成時に発生する例外に使用する再試行ポリシーを指定します。

戻り値:

CompletableFuture未処理の操作を表す 。 Task の結果は CommunicationClient(CommunicationClient) オブジェクトです。

getClientAsync

public CompletableFuture getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

1 つ以上の通信リスナーを含む指定されたサービスのパーティションを解決し、指定された listenerName に対応するエンドポイントと通信するクライアントを返します。 サービスのエンドポイントは、{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} の形式です。

パラメーター:

serviceUri - 解決するサービスの URI
partitionKey - 解決するパーティションを識別するキー
targetReplicaSelector - パーティション キーによって識別されるパーティション内のどのレプリカにクライアントが接続するかを指定します。
listenerName - クライアントが接続する必要がある、選択したレプリカのエンドポイント内のリスナーを指定します
retrySettings - クライアントの作成時に発生する例外に使用する再試行ポリシーを指定します。

戻り値:

CompletableFuture未処理の操作を表す 。 Task の結果は CommunicationClient(CommunicationClient) オブジェクトです。

reportOperationExceptionAsync

public CompletableFuture reportOperationExceptionAsync(TCommunicationClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

サービスにメッセージを送信するときに CommunicationClient で発生する例外を処理します

パラメーター:

client - 通信クライアント
exceptionInformation - サービスとの通信中に発生した例外に関する情報。
retrySettings - 報告された例外の処理に使用する再試行ポリシーを指定します。

戻り値:

CompletableFuture未処理の操作を表す 。 Task の結果は、この例外の OperationRetryControl 再試行ポリシーに関する情報を提供するオブジェクトです。

適用対象