Class SubscriberBuilder.Builder (1.4.12)

public abstract static class SubscriberBuilder.Builder

Inheritance

java.lang.Object > SubscriberBuilder.Builder

Constructors

Builder()

public Builder()

Methods

build()

public Subscriber build()
Returns
TypeDescription
Subscriber
Exceptions
TypeDescription
ApiException

setInitialLocation(SeekRequest initialLocation)

public abstract SubscriberBuilder.Builder setInitialLocation(SeekRequest initialLocation)
Parameter
NameDescription
initialLocationSeekRequest
Returns
TypeDescription
SubscriberBuilder.Builder

setMessageConsumer(Consumer<List<SequencedMessage>> messageConsumer)

public abstract SubscriberBuilder.Builder setMessageConsumer(Consumer<List<SequencedMessage>> messageConsumer)
Parameter
NameDescription
messageConsumerConsumer<List<SequencedMessage>>
Returns
TypeDescription
SubscriberBuilder.Builder

setPartition(Partition partition)

public abstract SubscriberBuilder.Builder setPartition(Partition partition)
Parameter
NameDescription
partitionPartition
Returns
TypeDescription
SubscriberBuilder.Builder

setResetHandler(SubscriberResetHandler resetHandler)

public abstract SubscriberBuilder.Builder setResetHandler(SubscriberResetHandler resetHandler)
Parameter
NameDescription
resetHandlerSubscriberResetHandler
Returns
TypeDescription
SubscriberBuilder.Builder

setStreamFactory(StreamFactories.SubscribeStreamFactory streamFactory)

public abstract SubscriberBuilder.Builder setStreamFactory(StreamFactories.SubscribeStreamFactory streamFactory)
Parameter
NameDescription
streamFactoryStreamFactories.SubscribeStreamFactory
Returns
TypeDescription
SubscriberBuilder.Builder

setSubscriptionPath(SubscriptionPath path)

public abstract SubscriberBuilder.Builder setSubscriptionPath(SubscriptionPath path)
Parameter
NameDescription
pathSubscriptionPath
Returns
TypeDescription
SubscriberBuilder.Builder