Class CommitterImpl (1.8.0)

public class CommitterImpl extends ProxyService implements Committer, RetryingConnectionObserver<SequencedCommitCursorResponse>

Inheritance

java.lang.Object > AbstractApiService > ProxyService > CommitterImpl

Implements

Committer, com.google.cloud.pubsublite.internal.wire.RetryingConnectionObserver<com.google.cloud.pubsublite.proto.SequencedCommitCursorResponse>

Constructors

CommitterImpl(StreamFactory<StreamingCommitCursorRequest,StreamingCommitCursorResponse> streamFactory, InitialCommitCursorRequest request)

public CommitterImpl(StreamFactory<StreamingCommitCursorRequest,StreamingCommitCursorResponse> streamFactory, InitialCommitCursorRequest request)
Parameters
NameDescription
streamFactoryStreamFactory<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
requestInitialCommitCursorRequest

Methods

commitOffset(Offset offset)

public ApiFuture<Void> commitOffset(Offset offset)
Parameter
NameDescription
offsetOffset
Returns
TypeDescription
ApiFuture<Void>

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)
Parameter
NameDescription
errorCheckedApiException
Overrides

onClientResponse(SequencedCommitCursorResponse value)

public void onClientResponse(SequencedCommitCursorResponse value)
Parameter
NameDescription
valueSequencedCommitCursorResponse
Exceptions
TypeDescription
CheckedApiException

stop()

protected void stop()
Overrides

triggerReinitialize(CheckedApiException streamError)

public void triggerReinitialize(CheckedApiException streamError)
Parameter
NameDescription
streamErrorCheckedApiException

waitUntilEmpty()

public void waitUntilEmpty()
Exceptions
TypeDescription
CheckedApiException