Package com.google.cloud.pubsublite.internal

Class ProxyService

java.lang.Object

com.google.api.core.AbstractApiService

com.google.cloud.pubsublite.internal.ProxyService

All Implemented Interfaces:

com.google.api.core.ApiService

Direct Known Subclasses:

AckSetTrackerImpl, ApiExceptionPublisher, AssignerImpl, AssigningSubscriber, BatchingCommitter, CommitterImpl, MultiPartitionSubscriber, PartitionCountWatchingPublisher, PublisherImpl, RoutingPublisher, SequenceAssigningPublisher, SinglePartitionPublisher, SinglePartitionSubscriber, SubscriberImpl, WrappingPublisher

public abstract class ProxyService
extends com.google.api.core.AbstractApiService

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.api.core.ApiService

com.google.api.core.ApiService.Listener, com.google.api.core.ApiService.State

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ProxyService(com.google.api.core.ApiService... services)
protected	ProxyService(Collection<T> services)

Method Summary

Modifier and Type	Method	Description
protected void	addServices(com.google.api.core.ApiService... services)
protected <T extends com.google.api.core.ApiService> void	addServices(Collection<T> services)
protected void	doStart()
protected void	doStop()
protected void	handlePermanentError(CheckedApiException error)
protected void	onPermanentError(CheckedApiException error)
protected void	start()
protected void	stop()

Methods inherited from class com.google.api.core.AbstractApiService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProxyService

protected ProxyService(Collection<T> services)

ProxyService

protected ProxyService(com.google.api.core.ApiService... services)
                throws com.google.api.gax.rpc.ApiException

Throws:

com.google.api.gax.rpc.ApiException

Method Detail

addServices

protected final <T extends com.google.api.core.ApiService> void addServices(Collection<T> services)
                                                                     throws com.google.api.gax.rpc.ApiException

Throws:

com.google.api.gax.rpc.ApiException

addServices

protected final void addServices(com.google.api.core.ApiService... services)
                          throws com.google.api.gax.rpc.ApiException

Throws:

com.google.api.gax.rpc.ApiException

start

protected void start()
              throws CheckedApiException

Throws:

CheckedApiException

stop

protected void stop()
             throws CheckedApiException

Throws:

CheckedApiException

handlePermanentError

protected void handlePermanentError(CheckedApiException error)

onPermanentError

protected final void onPermanentError(CheckedApiException error)

doStart

protected final void doStart()

Specified by:

doStart in class com.google.api.core.AbstractApiService

doStop

protected final void doStop()

Specified by:

doStop in class com.google.api.core.AbstractApiService