Class AckSetTrackerImpl (1.14.0)

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
Name Description
committer Committer

Methods

handlePermanentError(CheckedApiException error)

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

start()

protected void start()
Overrides
Exceptions
Type Description
CheckedApiException

stop()

protected synchronized void stop()
Overrides
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