Class CommitterImpl (1.14.4)

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
Name Description
streamFactory StreamFactory<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
request InitialCommitCursorRequest

Methods

commitOffset(Offset offset)

public ApiFuture<Void> commitOffset(Offset offset)
Parameter
Name Description
offset Offset
Returns
Type Description
ApiFuture<Void>

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)
Parameter
Name Description
error CheckedApiException
Overrides

onClientResponse(SequencedCommitCursorResponse value)

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

stop()

protected void stop()
Overrides

triggerReinitialize(CheckedApiException streamError)

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

waitUntilEmpty()

public void waitUntilEmpty()
Exceptions
Type Description
CheckedApiException