Compartilhar via


CommunicationClientFactory<TCommunicationClient> Interface

Parâmetros de tipo

TCommunicationClient

public interface CommunicationClientFactory

Define a interface que deve ser implementada para fornecer uma fábrica para que os clientes de comunicação conversem com um serviço do service fabric.

Resumo do método

Modificador e tipo Método e descrição
CompletableFuture<TCommunicationClient> getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Resolve novamente uma partição do serviço especificado que contém um ou mais ouvintes de comunicação e retorna um cliente para se comunicar com o ponto de extremidade correspondente ao ouvinteName especificado. O ponto de extremidade do serviço é do formulário - {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

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

Resolve uma partição do serviço especificado que contém um ou mais ouvintes de comunicação e retorna um cliente para se comunicar com o ponto de extremidade correspondente ao ouvinteName especificado. O ponto de extremidade do serviço é do formulário - {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

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

Manipula as exceções que ocorrem no CommunicationClient ao enviar uma mensagem para o Serviço

Detalhes do método

getClientAsync

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

Resolve novamente uma partição do serviço especificado que contém um ou mais ouvintes de comunicação e retorna um cliente para se comunicar com o ponto de extremidade correspondente ao ouvinteName especificado. O ponto de extremidade do serviço é do formulário - {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Parâmetros:

previousRsp - Valor de ResolvedServicePartition anterior
targetReplicaSelector - Especifica a qual réplica na partição identificada pela chave de partição, ao qual o cliente deve se conectar
listenerName - Especifica a qual ouvinte no ponto de extremidade do réplica escolhido, ao qual o cliente deve se conectar
retrySettings - Especifica a política de repetição que deve ser usada para exceções que ocorrem ao criar o cliente.

Retornos:

Um CompletableFuture que representa uma operação pendente. O resultado da Tarefa é o objeto CommunicationClient(CommunicationClient).

getClientAsync

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

Resolve uma partição do serviço especificado que contém um ou mais ouvintes de comunicação e retorna um cliente para se comunicar com o ponto de extremidade correspondente ao ouvinteName especificado. O ponto de extremidade do serviço é do formulário - {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Parâmetros:

serviceUri - Uri do serviço para resolve
partitionKey - Chave que identifica a partição para resolve
targetReplicaSelector - Especifica a qual réplica na partição identificada pela chave de partição, ao qual o cliente deve se conectar
listenerName - Especifica a qual ouvinte no ponto de extremidade do réplica escolhido, ao qual o cliente deve se conectar
retrySettings - Especifica a política de repetição que deve ser usada para exceções que ocorrem ao criar o cliente.

Retornos:

Um CompletableFuture que representa uma operação pendente. O resultado da Tarefa é o objeto CommunicationClient(CommunicationClient).

reportOperationExceptionAsync

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

Manipula as exceções que ocorrem no CommunicationClient ao enviar uma mensagem para o Serviço

Parâmetros:

client - Cliente de comunicação
exceptionInformation - Informações sobre a exceção que ocorreu durante a comunicação com o serviço.
retrySettings - Especifica a política de repetição que deve ser usada para lidar com a exceção relatada.

Retornos:

Um CompletableFuture que representa uma operação pendente. O resultado da Tarefa é um OperationRetryControl objeto que fornece informações sobre a política de repetição para essa exceção.

Aplica-se a