Class AckSetTrackerImpl
- java.lang.Object
-
- com.google.api.core.AbstractApiService
-
- com.google.cloud.pubsublite.internal.ProxyService
-
- com.google.cloud.pubsublite.cloudpubsub.internal.AckSetTrackerImpl
-
- All Implemented Interfaces:
com.google.api.core.ApiService
public class AckSetTrackerImpl extends ProxyService
-
-
Constructor Summary
Constructors Constructor Description AckSetTrackerImpl(Committer committer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidhandlePermanentError(CheckedApiException error)protected voidstart()protected voidstop()Runnabletrack(SequencedMessage message)voidwaitUntilCommitted()-
Methods inherited from class com.google.cloud.pubsublite.internal.ProxyService
addServices, addServices, doStart, doStop, onPermanentError
-
Methods inherited from class com.google.api.core.AbstractApiService
addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync
-
-
-
-
Constructor Detail
-
AckSetTrackerImpl
public AckSetTrackerImpl(Committer committer) throws com.google.api.gax.rpc.ApiException
- Throws:
com.google.api.gax.rpc.ApiException
-
-
Method Detail
-
track
public Runnable track(SequencedMessage message) throws CheckedApiException
- Throws:
CheckedApiException
-
waitUntilCommitted
public void waitUntilCommitted() throws CheckedApiException- Throws:
CheckedApiException
-
start
protected void start() throws CheckedApiException- Overrides:
startin classProxyService- Throws:
CheckedApiException
-
stop
protected void stop() throws CheckedApiException- Overrides:
stopin classProxyService- Throws:
CheckedApiException
-
handlePermanentError
protected void handlePermanentError(CheckedApiException error)
- Overrides:
handlePermanentErrorin classProxyService
-
-