Class AssignerImpl (1.14.1)

public class AssignerImpl extends ProxyService implements Assigner, RetryingConnectionObserver<PartitionAssignment>

Inheritance

java.lang.Object > AbstractApiService > ProxyService > AssignerImpl

Implements

Assigner, com.google.cloud.pubsublite.internal.wire.RetryingConnectionObserver<com.google.cloud.pubsublite.proto.PartitionAssignment>

Constructors

AssignerImpl(PartitionAssignmentServiceClient client, InitialPartitionAssignmentRequest initialRequest, PartitionAssignmentReceiver receiver)

public AssignerImpl(PartitionAssignmentServiceClient client, InitialPartitionAssignmentRequest initialRequest, PartitionAssignmentReceiver receiver)
Parameters
Name Description
client PartitionAssignmentServiceClient
initialRequest InitialPartitionAssignmentRequest
receiver PartitionAssignmentReceiver

Methods

onClientResponse(PartitionAssignment value)

public void onClientResponse(PartitionAssignment value)
Parameter
Name Description
value PartitionAssignment
Exceptions
Type Description
CheckedApiException

triggerReinitialize(CheckedApiException streamError)

public void triggerReinitialize(CheckedApiException streamError)
Parameter
Name Description
streamError CheckedApiException