software.chronicle.datagrid.internal.map

Interface KVSSubscription<K,V>

All Superinterfaces:

AutoCloseable, BaseSubscriber, Closeable, EventConsumer<K,V>, net.openhft.chronicle.core.io.QueryCloseable, SubscriptionCollection<MapEvent<K,V>>

All Known Subinterfaces:

ObjectSubscription<K,V>, RawKVSSubscription<K,V>

All Known Implementing Classes:

MapKVSSubscription, QueueObjectSubscription, RemoteKVSSubscription

public interface KVSSubscription<K,V>
extends SubscriptionCollection<MapEvent<K,V>>, BaseSubscriber, EventConsumer<K,V>

Method Summary

Modifier and Type	Method and Description
boolean	hasSubscribers()
default boolean	hasValueSubscribers()
default boolean	keyedView()
boolean	needsPrevious()
void	notifyEvent(MapEvent<K,V> changeEvent)
void	registerDownstream(@NotNull EventConsumer<K,V> subscription)
void	registerKeySubscriber(@NotNull RequestContext rc, @NotNull Subscriber<? super K> subscriber, @NotNull Filter<? super K> filter) Add a Subscription for the keys changed on this Map
void	registerTopicSubscriber(@NotNull RequestContext rc, @NotNull TopicSubscriber<? super K,? super V> subscriber)
void	setKvStore(KeyValueStore<K,V> store)
void	unregisterTopicSubscriber(@NotNull TopicSubscriber subscriber)

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

entrySubscriberCount, keySubscriberCount, registerSubscriber, subscriberCount, topicSubscriberCount, unregisterSubscriber

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

close, closeQuietly, closeQuietly

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosed, isClosing

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

index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription

Method Detail

registerKeySubscriber

void registerKeySubscriber(@NotNull
                           @NotNull RequestContext rc,
                           @NotNull
                           @NotNull Subscriber<? super K> subscriber,
                           @NotNull
                           @NotNull Filter<? super K> filter)

Add a Subscription for the keys changed on this Map

Parameters:

rc - RequestContext to use

subscriber - to add

filter - a list of filter operations

registerTopicSubscriber

void registerTopicSubscriber(@NotNull
                             @NotNull RequestContext rc,
                             @NotNull
                             @NotNull TopicSubscriber<? super K,? super V> subscriber)

unregisterTopicSubscriber

void unregisterTopicSubscriber(@NotNull
                               @NotNull TopicSubscriber subscriber)

registerDownstream

void registerDownstream(@NotNull
                        @NotNull EventConsumer<K,V> subscription)

keyedView

default boolean keyedView()

needsPrevious

boolean needsPrevious()

setKvStore

void setKvStore(KeyValueStore<K,V> store)

notifyEvent

void notifyEvent(MapEvent<K,V> changeEvent)

Specified by:

notifyEvent in interface EventConsumer<K,V>

hasSubscribers

boolean hasSubscribers()

hasValueSubscribers

default boolean hasValueSubscribers()