software.chronicle.datagrid.internal.pubsub

Class VanillaTopicSubscriberBuilder<T,M>

java.lang.Object

software.chronicle.datagrid.internal.pubsub.VanillaTopicSubscriberBuilder<T,M>

All Implemented Interfaces:

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

public class VanillaTopicSubscriberBuilder<T,M>
extends Object
implements TopicSubscriberBuilder<T,M>

Nested Class Summary

Nested classes/interfaces inherited from interface software.chronicle.datagrid.pubsub.TopicSubscriberBuilder

TopicSubscriberBuilder.MessageBiConsumer<T,M>

Constructor Summary

Constructors

Constructor and Description
VanillaTopicSubscriberBuilder()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

withEndOfSubscriptionHandler, withIndex, withIndexAware, withTcpBufferFull, withUsingMessage

Constructor Detail

VanillaTopicSubscriberBuilder

public VanillaTopicSubscriberBuilder()

Method Detail

withMessageHandler

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

Description copied from interface: TopicSubscriberBuilder

Sets the message handler for the subscriber.

The message handler will invoked on TopicSubscriber::onMessage

Specified by:

withMessageHandler in interface TopicSubscriberBuilder<T,M>

Parameters:

handler - to use for the subscriber

Returns:

this builder

withUsingTopic

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

Description copied from interface: TopicSubscriberBuilder

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

Specified by:

withUsingTopic in interface TopicSubscriberBuilder<T,M>

Parameters:

usingTopic - to re-use

Returns:

this builder

build

public TopicSubscriber<T,M> build()

Description copied from interface: BaseSubscriberBuilder

Creates and returns a new subscriber.

Specified by:

build in interface BaseSubscriberBuilder<TopicSubscriberBuilder<T,M>,TopicSubscriber<T,M>,M>

Returns:

a new subscriber

withEndOfSubscriptionHandler

public B withEndOfSubscriptionHandler(@NotNull
                                      @NotNull Runnable handler)

Description copied from interface: BaseSubscriberBuilder

Sets the end of subscription handler for the subscriber.

Specified by:

withEndOfSubscriptionHandler in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>

Parameters:

handler - to use for the subscriber

Returns:

this builder

withTcpBufferFull

public B withTcpBufferFull(@NotNull
                           @NotNull BooleanSupplier tcpBufferFullSupplier)

Description copied from interface: BaseSubscriberBuilder

Sets the tcp buffer full supplier to use for the subscriber.

Specified by:

withTcpBufferFull in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>

Parameters:

tcpBufferFullSupplier - to use for the subscriber

Returns:

this builder

withIndexAware

public B withIndexAware()

Description copied from interface: BaseSubscriberBuilder

Sets that the subscriber built should be an index aware subscriber.

Specified by:

withIndexAware in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>

Returns:

this builder

withIndex

public B withIndex(long initialIndex)

Description copied from interface: BaseSubscriberBuilder

Sets the initial index to use if this builder builds an index aware subscriber.

Specified by:

withIndex in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>

Parameters:

initialIndex - for the subscriber

Returns:

this builder

withUsingMessage

public B withUsingMessage(@NotNull
                          M usingMessage)

Description copied from interface: BaseSubscriberBuilder

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

Specified by:

withUsingMessage in interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>

Parameters:

usingMessage - to re-use

Returns:

this builder