FabricServiceRemotingPartitionClient Class

public class FabricServiceRemotingPartitionClient extends FabricServicePartitionClient implements ServiceRemotingPartitionClient

Specifies the Service partition client for Remoting communication

Constructor Summary

Constructor Description
FabricServiceRemotingPartitionClient(ServiceRemotingClientFactory remotingClientFactory, URI serviceUri)

Instantiates the Service partition client for remoting communication.

FabricServiceRemotingPartitionClient(ServiceRemotingClientFactory remotingClientFactory, URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Instantiates the Service partition client for remoting communication.

Method Summary

Modifier and Type Method and Description
CompletableFuture<byte[]> invokeAsync(ServiceRemotingMessageHeaders headers, byte[] requestMsgBody, CancellationToken cancellationToken)

A CompletableFuture that represents the asynchronous operation async call to remote object.

Inherited Members

FabricServicePartitionClient<C>.FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName) FabricServicePartitionClient<C>.FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey) FabricServicePartitionClient<C>.FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector) FabricServicePartitionClient<C>.FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName) FabricServicePartitionClient<C>.FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings) FabricServicePartitionClient<C>.getCommunicationClientFactory() ServicePartitionClient<TCommunicationClient>.getCommunicationClientFactory() FabricServicePartitionClient<C>.getLastResolvedServicePartition() ServicePartitionClient<TCommunicationClient>.getLastResolvedServicePartition() FabricServicePartitionClient<C>.getListenerName() ServicePartitionClient<TCommunicationClient>.getListenerName() FabricServicePartitionClient<C>.getPartitionKey() ServicePartitionClient<TCommunicationClient>.getPartitionKey() FabricServicePartitionClient<C>.getServiceUri() ServicePartitionClient<TCommunicationClient>.getServiceUri() FabricServicePartitionClient<C>.getTargetReplicaSelector() ServicePartitionClient<TCommunicationClient>.getTargetReplicaSelector()

Constructor Details

FabricServiceRemotingPartitionClient

public FabricServiceRemotingPartitionClient(ServiceRemotingClientFactory remotingClientFactory, URI serviceUri)

Instantiates the Service partition client for remoting communication.

Parameters:

remotingClientFactory - Remoting client factory
serviceUri - Actor service name

FabricServiceRemotingPartitionClient

public FabricServiceRemotingPartitionClient(ServiceRemotingClientFactory remotingClientFactory, URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Instantiates the Service partition client for remoting communication.

Parameters:

remotingClientFactory - Remoting client factory
serviceUri - Actor service name
partitionKey - The partition key used to identify the partition within the service.
targetReplicaSelector - Target replica information
listenerName - By default an actor service has only one listener for clients to connect to and communicate with. However it is possible to configure an actor service with more than one listeners, the listenerName parameter specifies the name of the listener to connect to.
retrySettings - Retry settings for the remote calls made by the partition client.

Method Details

invokeAsync

protected CompletableFuture invokeAsync(ServiceRemotingMessageHeaders headers, byte[] requestMsgBody, CancellationToken cancellationToken)

A CompletableFuture that represents the asynchronous operation async call to remote object.

Parameters:

headers - Request message headers
requestMsgBody - Message body
cancellationToken -

CancellationToken object to indicate the cancellation status of the operation.

Returns:

A CompletableFuture that represents the asynchronous operation async call to remote object.

Applies to