Class SinglePartitionSubscriber (1.13.6)

public class SinglePartitionSubscriber extends ProxyService implements Subscriber

Inheritance

java.lang.Object > AbstractApiService > ProxyService > SinglePartitionSubscriber

Implements

Subscriber

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

start()

protected void start()
Overrides
Exceptions
Type Description
CheckedApiException

stop()

protected void stop()
Overrides