Class SinglePartitionSubscriber (1.10.0)

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
NameDescription
receivercom.google.cloud.pubsub.v1.MessageReceiver
transformerMessageTransformer<SequencedMessage,com.google.pubsub.v1.PubsubMessage>
ackSetTrackercom.google.cloud.pubsublite.cloudpubsub.internal.AckSetTracker
nackHandlerNackHandler
wireSubscriberFactoryResettableSubscriberFactory
flowControlSettingsFlowControlSettings

Methods

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)
Parameter
NameDescription
errorCheckedApiException
Overrides

start()

protected void start()
Overrides Exceptions
TypeDescription
CheckedApiException

stop()

protected void stop()
Overrides