Class AckSetTrackerImpl (1.12.22)

public class AckSetTrackerImpl extends ProxyService implements AckSetTracker

Inheritance

java.lang.Object > AbstractApiService > ProxyService > AckSetTrackerImpl

Implements

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

Constructors

AckSetTrackerImpl(Committer committer)

public AckSetTrackerImpl(Committer committer)
Parameter
NameDescription
committerCommitter

Methods

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)
Parameter
NameDescription
errorCheckedApiException
Overrides

start()

protected void start()
Overrides
Exceptions
TypeDescription
CheckedApiException

stop()

protected synchronized void stop()
Overrides
Exceptions
TypeDescription
CheckedApiException

track(SequencedMessage message)

public synchronized Runnable track(SequencedMessage message)
Parameter
NameDescription
messageSequencedMessage
Returns
TypeDescription
Runnable
Exceptions
TypeDescription
CheckedApiException

waitUntilCommitted()

public synchronized void waitUntilCommitted()
Exceptions
TypeDescription
CheckedApiException