software.chronicle.datagrid.internal.pubsub

Class FilteringTopicSubscriber<T,M>

java.lang.Object

software.chronicle.datagrid.internal.pubsub.AbstractDelegatingSubscriber<Subscriber<? super M>>

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

All Implemented Interfaces:

EndOfConnection, BaseSubscriber, HasUsingMessage<M>, HasUsingTopic<T>, TopicSubscriber<T,M>

public final class FilteringTopicSubscriber<T,M>
extends AbstractDelegatingSubscriber<Subscriber<? super M>>
implements TopicSubscriber<T,M>

Constructor Summary

Constructors

Constructor and Description
FilteringTopicSubscriber(T topic, @NotNull Subscriber<? super M> subscriber)

Method Summary

Modifier and Type	Method and Description
void	onMessage(T t, M m) This method is invoked by DataGrid when a topic in a group has an new message/event

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

delegate, index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription

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

builder, indexAware, onEndOfConnection

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

index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription

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

usingTopic

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

usingMessage

Constructor Detail

FilteringTopicSubscriber

public FilteringTopicSubscriber(@NotNull
                                T topic,
                                @NotNull
                                @NotNull Subscriber<? super M> subscriber)

Method Detail

onMessage

public void onMessage(T t,
                      M m)
               throws InvalidSubscriberException

Description copied from interface: TopicSubscriber

This method is invoked by DataGrid when a topic in a group has an new message/event

Specified by:

onMessage in interface TopicSubscriber<T,M>

Parameters:

t - the message was associated with

m - published

Throws:

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