software.chronicle.datagrid.internal.pubsub

Class VanillaSubscriber<M>

java.lang.Object

software.chronicle.datagrid.internal.pubsub.AbstractBaseSubscriber<M>

software.chronicle.datagrid.internal.pubsub.VanillaSubscriber<M>

All Implemented Interfaces:

Consumer<M>, BaseSubscriber, HasUsingMessage<M>, Subscriber<M>

public final class VanillaSubscriber<M>
extends AbstractBaseSubscriber<M>
implements Subscriber<M>

Constructor Summary

Constructors

Constructor and Description
VanillaSubscriber(@NotNull Runnable endOfSubscriptionHandler, @NotNull BooleanSupplier tcpBufferFullSupplier, boolean indexAware, long index, M usingMessage, @NotNull Runnable endOfBootstrapHandler, SubscriberBuilder.MessageConsumer<? super M> messageHandler)

Method Summary

Modifier and Type	Method and Description
void	onEndOfBootStrap() This method is optionally invoked by Datagrid upon end of bootstrapping.
void	onMessage(M m) This method is invoked by DataGrid when there is a new unseen event.

Methods inherited from class software.chronicle.datagrid.internal.pubsub.AbstractBaseSubscriber

index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription, usingMessage

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.Subscriber

accept, builder, indexAware

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

index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription

Methods inherited from interface java.util.function.Consumer

andThen

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

usingMessage

Constructor Detail

VanillaSubscriber

public VanillaSubscriber(@NotNull
                         @NotNull Runnable endOfSubscriptionHandler,
                         @NotNull
                         @NotNull BooleanSupplier tcpBufferFullSupplier,
                         boolean indexAware,
                         long index,
                         M usingMessage,
                         @NotNull
                         @NotNull Runnable endOfBootstrapHandler,
                         @NotNull
                         SubscriberBuilder.MessageConsumer<? super M> messageHandler)

Method Detail

onMessage

public void onMessage(M m)
               throws InvalidSubscriberException

Description copied from interface: Subscriber

This method is invoked by DataGrid when there is a new unseen event.

Specified by:

onMessage in interface Subscriber<M>

Parameters:

m - event

Throws:

InvalidSubscriberException - is thrown if this subscriber is no longer valid.

onEndOfBootStrap

public void onEndOfBootStrap()

Description copied from interface: Subscriber

This method is optionally invoked by Datagrid upon end of bootstrapping.

Currently, only a TopologySubscription support this call-back.

Specified by:

onEndOfBootStrap in interface Subscriber<M>