Class AckSetTrackerImpl (1.8.0)

Version 1.8.0

• 1.15.0 (latest)
• 1.14.8
• 1.13.8
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

public class AckSetTrackerImpl extends ProxyService implements AckSetTracker

Inheritance

java.lang.Object > AbstractApiService > ProxyService > AckSetTrackerImpl

Implements

com.google.cloud.pubsublite.cloudpubsub.internal.AckSetTracker

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

AckSetTrackerImpl(Committer committer)

public AckSetTrackerImpl(Committer committer)

Parameter

Name	Description
committer	Committer

Methods

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)

Parameter

Name	Description
error	CheckedApiException

Overrides

ProxyService.handlePermanentError(CheckedApiException error)

start()

protected void start()

Overrides

ProxyService.start()

Exceptions

Type	Description
CheckedApiException

stop()

protected synchronized void stop()

Overrides

ProxyService.stop()

Exceptions

Type	Description
CheckedApiException

track(SequencedMessage message)

public synchronized Runnable track(SequencedMessage message)

Parameter

Name	Description
message	SequencedMessage

Returns

Type	Description
Runnable

Exceptions

Type	Description
CheckedApiException

waitUntilCommitted()

public synchronized void waitUntilCommitted()

Exceptions

Type	Description
CheckedApiException