public interface TopicSubscriberBuilder<T,M> extends BaseSubscriberBuilder<TopicSubscriberBuilder<T,M>,TopicSubscriber<T,M>,M>
Modifier and Type | Interface and Description |
---|---|
static interface |
TopicSubscriberBuilder.MessageBiConsumer<T,M> |
Modifier and Type | Method and Description |
---|---|
TopicSubscriberBuilder<T,M> |
withMessageHandler(@NotNull TopicSubscriberBuilder.MessageBiConsumer<? super T,? super M> handler)
Sets the message handler for the subscriber.
|
TopicSubscriberBuilder<T,M> |
withUsingTopic(T usingTopic)
Provides a re-usable object that will be recycled
for subscriber topics.
|
build, withEndOfSubscriptionHandler, withIndex, withIndexAware, withTcpBufferFull, withUsingMessage
TopicSubscriberBuilder<T,M> withMessageHandler(@NotNull @NotNull TopicSubscriberBuilder.MessageBiConsumer<? super T,? super M> handler)
The message handler will invoked on TopicSubscriber::onMessage
handler
- to use for the subscriberTopicSubscriberBuilder<T,M> withUsingTopic(@NotNull T usingTopic)
usingTopic
- to re-useCopyright © 2021. All rights reserved.