Class AssignerImpl (1.12.22)

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
NameDescription
clientPartitionAssignmentServiceClient
initialRequestInitialPartitionAssignmentRequest
receiverPartitionAssignmentReceiver

Methods

onClientResponse(PartitionAssignment value)

public void onClientResponse(PartitionAssignment value)
Parameter
NameDescription
valuePartitionAssignment
Exceptions
TypeDescription
CheckedApiException

triggerReinitialize(CheckedApiException streamError)

public void triggerReinitialize(CheckedApiException streamError)
Parameter
NameDescription
streamErrorCheckedApiException