Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Class CommitterImpl (1.12.22)

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`