Class SinglePartitionSubscriber (1.12.9)

Version 1.12.9

• 1.14.8 (latest)
• 1.14.7
• 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 SinglePartitionSubscriber extends ProxyService implements Subscriber

Inheritance

java.lang.Object > AbstractApiService > ProxyService > SinglePartitionSubscriber

Implements

Subscriber

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

SinglePartitionSubscriber(MessageReceiver receiver, MessageTransformer<SequencedMessage,PubsubMessage> transformer, AckSetTracker ackSetTracker, NackHandler nackHandler, ResettableSubscriberFactory wireSubscriberFactory, FlowControlSettings flowControlSettings)

public SinglePartitionSubscriber(MessageReceiver receiver, MessageTransformer<SequencedMessage,PubsubMessage> transformer, AckSetTracker ackSetTracker, NackHandler nackHandler, ResettableSubscriberFactory wireSubscriberFactory, FlowControlSettings flowControlSettings)

Parameters
Name	Description
receiver	com.google.cloud.pubsub.v1.MessageReceiver
transformer	MessageTransformer<SequencedMessage,com.google.pubsub.v1.PubsubMessage>
ackSetTracker	com.google.cloud.pubsublite.cloudpubsub.internal.AckSetTracker
nackHandler	NackHandler
wireSubscriberFactory	ResettableSubscriberFactory
flowControlSettings	FlowControlSettings

Methods

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)

Parameter
Name	Description
error	CheckedApiException

Overrides

ProxyService.handlePermanentError(CheckedApiException error)

start()

protected void start()

Overrides

ProxyService.start()

Exceptions
Type	Description
CheckedApiException

stop()

protected void stop()

Overrides

ProxyService.stop()