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>

Inherited Members

AbstractApiService.addListener(ApiService.Listener,Executor)

AbstractApiService.awaitRunning()

AbstractApiService.awaitRunning(long,TimeUnit)

AbstractApiService.awaitTerminated()

AbstractApiService.awaitTerminated(long,TimeUnit)

AbstractApiService.failureCause()

AbstractApiService.isRunning()

AbstractApiService.notifyFailed(Throwable)

AbstractApiService.notifyStarted()

AbstractApiService.notifyStopped()

AbstractApiService.startAsync()

AbstractApiService.state()

AbstractApiService.stopAsync()

ProxyService.<T>addServices(Collection<T>)

ProxyService.addServices(ApiService)

ProxyService.doStart()

ProxyService.doStop()

ProxyService.handlePermanentError(CheckedApiException)

ProxyService.onPermanentError(CheckedApiException)

ProxyService.start()

ProxyService.stop()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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

ProxyService.handlePermanentError(CheckedApiException error)

onClientResponse(SequencedCommitCursorResponse value)

public void onClientResponse(SequencedCommitCursorResponse value)

Parameter

Name	Description
value	`SequencedCommitCursorResponse`

Exceptions

Type	Description
CheckedApiException

stop()

protected void stop()

Overrides

ProxyService.stop()

triggerReinitialize(CheckedApiException streamError)

public void triggerReinitialize(CheckedApiException streamError)

Parameter

Name	Description
streamError	`CheckedApiException`

waitUntilEmpty()

public void waitUntilEmpty()

Exceptions

Type	Description
CheckedApiException