public final class FilteringTopicSubscriber<T,M> extends AbstractDelegatingSubscriber<Subscriber<? super M>> implements TopicSubscriber<T,M>
Constructor and Description |
---|
FilteringTopicSubscriber(T topic,
@NotNull Subscriber<? super M> subscriber) |
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
|
delegate, index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, indexAware, onEndOfConnection
index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription
usingTopic
usingMessage
public FilteringTopicSubscriber(@NotNull T topic, @NotNull @NotNull Subscriber<? super M> subscriber)
public void onMessage(T t, M m) throws InvalidSubscriberException
TopicSubscriber
onMessage
in interface TopicSubscriber<T,M>
t
- the message was associated withm
- publishedInvalidSubscriberException
- is thrown if this subscriber is no longer valid.Copyright © 2021. All rights reserved.