Class SubscriberImpl (1.16.2)

1.16.2 (latest) 1.16.1 1.15.21 1.14.8 1.13.8 1.12.22 1.11.2 1.10.0 1.9.4 1.8.0 1.7.1 1.6.3 1.5.5 1.4.12

public class SubscriberImpl extends ProxyService implements Subscriber, RetryingConnectionObserver<List<SequencedMessage>>

Inheritance

java.lang.Object > AbstractApiService > ProxyService > SubscriberImpl

Implements

Subscriber, com.google.cloud.pubsublite.internal.wire.RetryingConnectionObserver<java.util.List<com.google.cloud.pubsublite.proto.SequencedMessage>>

Inherited Members

AbstractApiService.addListener(ApiService.Listener,Executor)

AbstractApiService.awaitRunning()

AbstractApiService.awaitRunning(long,TimeUnit)

AbstractApiService.awaitTerminated()

AbstractApiService.awaitTerminated(long,TimeUnit)

AbstractApiService.failureCause()

AbstractApiService.isRunning()

AbstractApiService.notifyFailed(Throwable)

AbstractApiService.notifyStarted()

AbstractApiService.notifyStopped()

AbstractApiService.startAsync()

AbstractApiService.state()

AbstractApiService.stopAsync()

ProxyService.<T>addServices(Collection<T>)

ProxyService.addServices(ApiService)

ProxyService.doStart()

ProxyService.doStop()

ProxyService.handlePermanentError(CheckedApiException)

ProxyService.onPermanentError(CheckedApiException)

ProxyService.start()

ProxyService.stop()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

SubscriberImpl(StreamFactories.SubscribeStreamFactory streamFactory, InitialSubscribeRequest baseInitialRequest, SeekRequest initialLocation, Consumer<List<SequencedMessage>> messageConsumer, SubscriberResetHandler resetHandler, boolean retryStreamRaces)

public SubscriberImpl(StreamFactories.SubscribeStreamFactory streamFactory, InitialSubscribeRequest baseInitialRequest, SeekRequest initialLocation, Consumer<List<SequencedMessage>> messageConsumer, SubscriberResetHandler resetHandler, boolean retryStreamRaces)

Parameters
Name	Description
streamFactory	StreamFactories.SubscribeStreamFactory
baseInitialRequest	InitialSubscribeRequest
initialLocation	SeekRequest
messageConsumer	Consumer<List<SequencedMessage>>
resetHandler	SubscriberResetHandler
retryStreamRaces	boolean

Methods

allowFlow(FlowControlRequest clientRequest)

public void allowFlow(FlowControlRequest clientRequest)

Parameter
Name	Description
clientRequest	FlowControlRequest

Exceptions
Type	Description
CheckedApiException

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)

Parameter
Name	Description
error	CheckedApiException

Overrides

ProxyService.handlePermanentError(CheckedApiException error)

onClientResponse(List<SequencedMessage> messages)

public void onClientResponse(List<SequencedMessage> messages)

Parameter
Name	Description
messages	List<SequencedMessage>

Exceptions
Type	Description
CheckedApiException

reset()

public void reset()

start()

protected void start()

Overrides

ProxyService.start()

stop()

protected void stop()

Overrides

ProxyService.stop()

triggerReinitialize(CheckedApiException streamError)

public void triggerReinitialize(CheckedApiException streamError)

Parameter
Name	Description
streamError	CheckedApiException