software.chronicle.datagrid.internal.pubsub

Class AbstractDelegatingSubscriber<T extends BaseSubscriber>

java.lang.Object

software.chronicle.datagrid.internal.pubsub.AbstractDelegatingSubscriber<T>

All Implemented Interfaces:

BaseSubscriber

Direct Known Subclasses:

FilteringTopicSubscriber, VanillaIndexAwareSubscriber, VanillaIndexAwareTopicSubscriber

public abstract class AbstractDelegatingSubscriber<T extends BaseSubscriber>
extends Object
implements BaseSubscriber

Constructor Summary

Constructors

Constructor and Description
AbstractDelegatingSubscriber(T subscriber)

Method Summary

Modifier and Type	Method and Description
protected T	delegate()
long	index() Returns the last index seen by this IndexAware.
void	index(long index) Sets the last index seen by this IndexAware.
boolean	isIndexAware() Returns if this BaseSubscriber implements BaseSubscriber.index() and BaseSubscriber.index(long).
boolean	isTcpBufferFullEnough() Returns if this TcpAware has a TCP/IP buffer that should not be filled with more data.
void	onEndOfSubscription() This method is invoked by Datagrid upon end of subscription.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractDelegatingSubscriber

public AbstractDelegatingSubscriber(@NotNull
                                    T subscriber)

Method Detail

delegate

protected T delegate()

onEndOfSubscription

public void onEndOfSubscription()

Description copied from interface: BaseSubscriber

This method is invoked by Datagrid upon end of subscription.

Specified by:

onEndOfSubscription in interface BaseSubscriber

isTcpBufferFullEnough

public boolean isTcpBufferFullEnough()

Description copied from interface: BaseSubscriber

Returns if this TcpAware has a TCP/IP buffer that should not be filled with more data.

Specified by:

isTcpBufferFullEnough in interface BaseSubscriber

Returns:

if this TcpAware has a TCP/IP buffer that should not be filled with more data

isIndexAware

public boolean isIndexAware()

Description copied from interface: BaseSubscriber

Returns if this BaseSubscriber implements BaseSubscriber.index() and BaseSubscriber.index(long).

Specified by:

isIndexAware in interface BaseSubscriber

Returns:

if this BaseSubscriber implements BaseSubscriber.index() and BaseSubscriber.index(long)

index

public long index()

Description copied from interface: BaseSubscriber

Returns the last index seen by this IndexAware.

The index is guaranteed to be set prior to invocation of any onMessage() method.

This is an optional method that is only implemented for BaseSubscriber instances that returns true when BaseSubscriber.isIndexAware() is invoked.

If implemented, This method is invoked by Datagrid upon end of bootstrapping.

Specified by:

index in interface BaseSubscriber

Returns:

the last seen index

index

public void index(long index)

Description copied from interface: BaseSubscriber

Sets the last index seen by this IndexAware.

This is an optional method that is only implemented for BaseSubscriber instances that returns true when BaseSubscriber.isIndexAware() is invoked.

Specified by:

index in interface BaseSubscriber