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 void
handlePermanentError(CheckedApiException error)
protected void
start()
protected void
stop()
Runnable
track(SequencedMessage message)
void
waitUntilCommitted()
-
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:
start
in classProxyService
- Throws:
CheckedApiException
-
stop
protected void stop() throws CheckedApiException
- Overrides:
stop
in classProxyService
- Throws:
CheckedApiException
-
handlePermanentError
protected void handlePermanentError(CheckedApiException error)
- Overrides:
handlePermanentError
in classProxyService
-
-