public class VanillaTopicSubscriberBuilder<T,M> extends Object implements TopicSubscriberBuilder<T,M>
TopicSubscriberBuilder.MessageBiConsumer<T,M>
Constructor and Description |
---|
VanillaTopicSubscriberBuilder() |
Modifier and Type | Method and Description |
---|---|
TopicSubscriber<T,M> |
build()
Creates and returns a new subscriber.
|
B |
withEndOfSubscriptionHandler(@NotNull Runnable handler)
Sets the end of subscription handler for the
subscriber.
|
B |
withIndex(long initialIndex)
Sets the initial index to use if this builder
builds an index aware subscriber.
|
B |
withIndexAware()
Sets that the subscriber built should be
an index aware subscriber.
|
TopicSubscriberBuilder<T,M> |
withMessageHandler(@NotNull TopicSubscriberBuilder.MessageBiConsumer<? super T,? super M> handler)
Sets the message handler for the subscriber.
|
B |
withTcpBufferFull(@NotNull BooleanSupplier tcpBufferFullSupplier)
Sets the tcp buffer full supplier to use for
the subscriber.
|
B |
withUsingMessage(M usingMessage)
Provides a re-usable object that will be recycled
for subscriber messages.
|
TopicSubscriberBuilder<T,M> |
withUsingTopic(T usingTopic)
Provides a re-usable object that will be recycled
for subscriber topics.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
withEndOfSubscriptionHandler, withIndex, withIndexAware, withTcpBufferFull, withUsingMessage
public TopicSubscriberBuilder<T,M> withMessageHandler(@NotNull @NotNull TopicSubscriberBuilder.MessageBiConsumer<? super T,? super M> handler)
TopicSubscriberBuilder
The message handler will invoked on TopicSubscriber::onMessage
withMessageHandler
in interface TopicSubscriberBuilder<T,M>
handler
- to use for the subscriberpublic TopicSubscriberBuilder<T,M> withUsingTopic(@NotNull T usingTopic)
TopicSubscriberBuilder
withUsingTopic
in interface TopicSubscriberBuilder<T,M>
usingTopic
- to re-usepublic TopicSubscriber<T,M> build()
BaseSubscriberBuilder
build
in interface BaseSubscriberBuilder<TopicSubscriberBuilder<T,M>,TopicSubscriber<T,M>,M>
public B withEndOfSubscriptionHandler(@NotNull @NotNull Runnable handler)
BaseSubscriberBuilder
withEndOfSubscriptionHandler
in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>
handler
- to use for the subscriberpublic B withTcpBufferFull(@NotNull @NotNull BooleanSupplier tcpBufferFullSupplier)
BaseSubscriberBuilder
withTcpBufferFull
in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>
tcpBufferFullSupplier
- to use for the subscriberpublic B withIndexAware()
BaseSubscriberBuilder
withIndexAware
in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>
public B withIndex(long initialIndex)
BaseSubscriberBuilder
withIndex
in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>
initialIndex
- for the subscriberpublic B withUsingMessage(@NotNull M usingMessage)
BaseSubscriberBuilder
withUsingMessage
in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>
usingMessage
- to re-useCopyright © 2021. All rights reserved.