CommunicationClientFactoryBase<T> クラス

protected CommunicationClientFactoryBase()

通信クライアント ファクトリの新しいインスタンスを初期化します。

protected CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List exceptionHandlers)

通信クライアント ファクトリの新しいインスタンスを初期化します。

パラメーター:

protected CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List exceptionHandlers, String traceId)

通信クライアント ファクトリの新しいインスタンスを初期化します。

パラメーター:

protected abstract void abortClient(T client)

指定されたクライアントを中止します

パラメーター:

protected abstract CompletableFuture createClientAsync(String endpoint)

パラメーター:

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

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

パラメーター:

戻り値:

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

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

パラメーター:

戻り値:

public List getExceptionHandlers()

クライアントからサービスへの通信チャネルで例外を処理するためのカスタム例外ハンドラーを取得します。

戻り値:

public ServicePartitionResolver getServiceResolver()

サービス エンドポイントを解決するためにクライアント ファクトリによって使用される ServicePartitionResolver を取得します。

戻り値:

protected String getTraceId()

CommunicationClientFactory のインスタンスを識別するために使用されるトレース識別子を取得します。 これは、トレース/ログ記録の関連付け識別子として使用されます。

戻り値:

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

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

パラメーター:

戻り値:

protected abstract boolean validateClient(String endpoint, T client)

クライアントがまだ有効で、 パラメーターで指定されたエンドポイントに接続されている場合は true を返します。

パラメーター:

戻り値:

protected abstract boolean validateClient(T client)

クライアントがまだ有効な場合は true を返します。 接続指向トランスポートでは、このメソッドを使用して、クライアントがサービスに接続されなくなったことを示すことができます。

パラメーター:

戻り値: