software.chronicle.datagrid.pubsub

Interface TopicSubscriberBuilder<T,M>

All Superinterfaces:

BaseSubscriberBuilder<TopicSubscriberBuilder<T,M>,TopicSubscriber<T,M>,M>

All Known Implementing Classes:

VanillaTopicSubscriberBuilder

public interface TopicSubscriberBuilder<T,M>
extends BaseSubscriberBuilder<TopicSubscriberBuilder<T,M>,TopicSubscriber<T,M>,M>

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	TopicSubscriberBuilder.MessageBiConsumer<T,M>

Method Summary

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.

Methods inherited from interface software.chronicle.datagrid.pubsub.BaseSubscriberBuilder

build, withEndOfSubscriptionHandler, withIndex, withIndexAware, withTcpBufferFull, withUsingMessage

Method Detail

withMessageHandler

TopicSubscriberBuilder<T,M> withMessageHandler(@NotNull
                                               @NotNull TopicSubscriberBuilder.MessageBiConsumer<? super T,? super M> handler)

Sets the message handler for the subscriber.

The message handler will invoked on TopicSubscriber::onMessage

Parameters:

handler - to use for the subscriber

Returns:

this builder

withUsingTopic

TopicSubscriberBuilder<T,M> withUsingTopic(@NotNull
                                           T usingTopic)

Provides a re-usable object that will be recycled for subscriber topics.

Parameters:

usingTopic - to re-use

Returns:

this builder