Package com.google.cloud.pubsublite.internal.wire

Class AssignerImpl

java.lang.Object

com.google.api.core.AbstractApiService

com.google.cloud.pubsublite.internal.ProxyService

com.google.cloud.pubsublite.internal.wire.AssignerImpl

All Implemented Interfaces:

com.google.api.core.ApiService, Assigner, RetryingConnectionObserver<PartitionAssignment>

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

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.api.core.ApiService

com.google.api.core.ApiService.Listener, com.google.api.core.ApiService.State

Constructor Summary

Constructors

Constructor	Description
AssignerImpl(PartitionAssignmentServiceClient client, InitialPartitionAssignmentRequest initialRequest, PartitionAssignmentReceiver receiver)

Method Summary

Modifier and Type	Method	Description
void	onClientResponse(PartitionAssignment value)
void	triggerReinitialize(CheckedApiException streamError)

Methods inherited from class com.google.cloud.pubsublite.internal.ProxyService

addServices, addServices, doStart, doStop, handlePermanentError, onPermanentError, start, stop

Methods inherited from class com.google.api.core.AbstractApiService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.google.api.core.ApiService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Constructor Detail

AssignerImpl

public AssignerImpl(PartitionAssignmentServiceClient client,
                    InitialPartitionAssignmentRequest initialRequest,
                    PartitionAssignmentReceiver receiver)
             throws com.google.api.gax.rpc.ApiException

Throws:

com.google.api.gax.rpc.ApiException

Method Detail

triggerReinitialize

public void triggerReinitialize(CheckedApiException streamError)

Specified by:

triggerReinitialize in interface RetryingConnectionObserver<PartitionAssignment>

onClientResponse

public void onClientResponse(PartitionAssignment value)
                      throws CheckedApiException

Specified by:

onClientResponse in interface RetryingConnectionObserver<PartitionAssignment>

Throws:

CheckedApiException