software.chronicle.datagrid.internal.map

Class MapKVSSubscription<K,V>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

software.chronicle.datagrid.internal.map.MapKVSSubscription<K,V>

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.ManagedCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, EventConsumer<K,V>, KVSSubscription<K,V>, ObjectSubscription<K,V>, RawKVSSubscription<K,V>, BaseSubscriber, SubscriptionCollection<MapEvent<K,V>>

public final class MapKVSSubscription<K,V>
extends net.openhft.chronicle.core.io.SimpleCloseable
implements ObjectSubscription<K,V>, RawKVSSubscription<K,V>

Field Summary

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT

Constructor Summary

Constructors

Constructor and Description
MapKVSSubscription(@Nullable Class viewType, @Nullable Asset asset)
MapKVSSubscription(@NotNull RequestContext requestContext, @NotNull Asset asset)

Method Summary

Modifier and Type	Method and Description
int	entrySubscriberCount()
boolean	hasSubscribers()
boolean	hasValueSubscribers()
boolean	keyedView()
int	keySubscriberCount()
boolean	needsPrevious()
void	notifyEvent(@NotNull MapEvent<K,V> changeEvent)
void	onEndOfSubscription() This method is invoked by Datagrid upon end of subscription.
protected void	performClose()
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	registerSubscriber(@NotNull RequestContext rc, @NotNull Subscriber<? super MapEvent<K,V>> subscriber, @NotNull Filter<? super MapEvent<K,V>> filter)
void	registerTopicSubscriber(@NotNull RequestContext rc, @NotNull TopicSubscriber<? super K,? super V> subscriber)
void	setKvStore(KeyValueStore<K,V> kvStore)
int	topicSubscriberCount()
void	unregisterDownstream(EventConsumer<K,V> subscription)
void	unregisterSubscriber(@NotNull Subscriber subscriber)
void	unregisterTopicSubscriber(@NotNull TopicSubscriber subscriber)

Methods inherited from class net.openhft.chronicle.core.io.SimpleCloseable

close, isClosed

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.internal.map.KVSSubscription

registerKeySubscriber

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

subscriberCount

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

close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed

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

isClosed, isClosing, throwExceptionIfClosed

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

referenceId, referenceName, temporary

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

createdHere, throwExceptionIfClosed, warnAndCloseIfNotClosed

Constructor Detail

MapKVSSubscription

public MapKVSSubscription(@NotNull
                          @NotNull RequestContext requestContext,
                          @NotNull
                          @NotNull Asset asset)

MapKVSSubscription

public MapKVSSubscription(@Nullable
                          @Nullable Class viewType,
                          @Nullable
                          @Nullable Asset asset)

Method Detail

performClose

protected void performClose()

Overrides:

performClose in class net.openhft.chronicle.core.io.SimpleCloseable

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

keyedView

public boolean keyedView()

Specified by:

keyedView in interface KVSSubscription<K,V>

setKvStore

public void setKvStore(KeyValueStore<K,V> kvStore)

Specified by:

setKvStore in interface KVSSubscription<K,V>

notifyEvent

public void notifyEvent(@NotNull
                        @NotNull MapEvent<K,V> changeEvent)

Specified by:

notifyEvent in interface EventConsumer<K,V>

Specified by:

notifyEvent in interface KVSSubscription<K,V>

keySubscriberCount

public int keySubscriberCount()

Specified by:

keySubscriberCount in interface SubscriptionCollection<MapEvent<K,V>>

entrySubscriberCount

public int entrySubscriberCount()

Specified by:

entrySubscriberCount in interface SubscriptionCollection<MapEvent<K,V>>

topicSubscriberCount

public int topicSubscriberCount()

Specified by:

topicSubscriberCount in interface SubscriptionCollection<MapEvent<K,V>>

hasSubscribers

public boolean hasSubscribers()

Specified by:

hasSubscribers in interface KVSSubscription<K,V>

hasValueSubscribers

public boolean hasValueSubscribers()

Specified by:

hasValueSubscribers in interface KVSSubscription<K,V>

needsPrevious

public boolean needsPrevious()

Specified by:

needsPrevious in interface KVSSubscription<K,V>

registerSubscriber

public void registerSubscriber(@NotNull
                               @NotNull RequestContext rc,
                               @NotNull
                               @NotNull Subscriber<? super MapEvent<K,V>> subscriber,
                               @NotNull
                               @NotNull Filter<? super MapEvent<K,V>> filter)

Specified by:

registerSubscriber in interface SubscriptionCollection<MapEvent<K,V>>

registerKeySubscriber

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

Description copied from interface: KVSSubscription

Add a Subscription for the keys changed on this Map

Specified by:

registerKeySubscriber in interface KVSSubscription<K,V>

Parameters:

rc - RequestContext to use

subscriber - to add

filter - a list of filter operations

registerTopicSubscriber

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

Specified by:

registerTopicSubscriber in interface KVSSubscription<K,V>

registerDownstream

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

Specified by:

registerDownstream in interface KVSSubscription<K,V>

unregisterDownstream

public void unregisterDownstream(EventConsumer<K,V> subscription)

unregisterSubscriber

public void unregisterSubscriber(@NotNull
                                 @NotNull Subscriber subscriber)

Specified by:

unregisterSubscriber in interface SubscriptionCollection<MapEvent<K,V>>

unregisterTopicSubscriber

public void unregisterTopicSubscriber(@NotNull
                                      @NotNull TopicSubscriber subscriber)

Specified by:

unregisterTopicSubscriber in interface KVSSubscription<K,V>