Partager via


CommunicationClientFactory<TCommunicationClient> Interface

Paramètres de type

TCommunicationClient

public interface CommunicationClientFactory

Définit l’interface qui doit être implémentée pour fournir une fabrique pour que les clients de communication communiquent avec un service Service Fabric.

Résumé de la méthode

Modificateur et type Méthode et description
CompletableFuture<TCommunicationClient> getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Résout à nouveau une partition du service spécifié contenant un ou plusieurs écouteurs de communication et retourne un client pour communiquer avec le point de terminaison correspondant à l’écouteurName donné. Le point de terminaison du service est de la forme : {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}

CompletableFuture<TCommunicationClient> getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Résout une partition du service spécifié contenant un ou plusieurs écouteurs de communication et retourne un client pour communiquer avec le point de terminaison correspondant à l’écouteurName donné. Le point de terminaison du service est de la forme : {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}

CompletableFuture<OperationRetryControl> reportOperationExceptionAsync(TCommunicationClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

Gère les exceptions qui se produisent dans CommunicationClient lors de l’envoi d’un message au service

Détails de la méthode

getClientAsync

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

Résout à nouveau une partition du service spécifié contenant un ou plusieurs écouteurs de communication et retourne un client pour communiquer avec le point de terminaison correspondant à l’écouteurName donné. Le point de terminaison du service est de la forme : {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}

Paramètres:

previousRsp - Valeur resolvedServicePartition précédente
targetReplicaSelector - Spécifie à quelle réplica dans la partition identifiée par la clé de partition, le client doit se connecter
listenerName - Spécifie l’écouteur dans le point de terminaison du réplica choisi, auquel le client doit se connecter
retrySettings - Spécifie la stratégie de nouvelle tentative qui doit être utilisée pour les exceptions qui se produisent lors de la création du client.

Retours:

qui représente l’opération CompletableFuture en suspens. Le résultat de la tâche est l’objet CommunicationClient(CommunicationClient).

getClientAsync

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

Résout une partition du service spécifié contenant un ou plusieurs écouteurs de communication et retourne un client pour communiquer avec le point de terminaison correspondant à l’écouteurName donné. Le point de terminaison du service est de la forme : {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}

Paramètres:

serviceUri - URI du service à résoudre
partitionKey - Clé qui identifie la partition à résoudre
targetReplicaSelector - Spécifie à quelle réplica dans la partition identifiée par la clé de partition, le client doit se connecter
listenerName - Spécifie l’écouteur dans le point de terminaison du réplica choisi, auquel le client doit se connecter
retrySettings - Spécifie la stratégie de nouvelle tentative qui doit être utilisée pour les exceptions qui se produisent lors de la création du client.

Retours:

qui représente l’opération CompletableFuture en suspens. Le résultat de la tâche est l’objet CommunicationClient(CommunicationClient).

reportOperationExceptionAsync

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

Gère les exceptions qui se produisent dans CommunicationClient lors de l’envoi d’un message au service

Paramètres:

client - Client de communication
exceptionInformation - Informations sur l’exception qui s’est produite lors de la communication avec le service.
retrySettings - Spécifie la stratégie de nouvelle tentative qui doit être utilisée pour gérer l’exception signalée.

Retours:

qui représente l’opération CompletableFuture en suspens. Le résultat de la tâche est un OperationRetryControl objet qui fournit des informations sur la stratégie de nouvelle tentative pour cette exception.

S’applique à