public final class MapKVSSubscription<K,V> extends net.openhft.chronicle.core.io.SimpleCloseable implements ObjectSubscription<K,V>, RawKVSSubscription<K,V>
Constructor and Description |
---|
MapKVSSubscription(@Nullable Class viewType,
@Nullable Asset asset) |
MapKVSSubscription(@NotNull RequestContext requestContext,
@NotNull Asset asset) |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
subscriberCount
close, closeQuietly, closeQuietly
public MapKVSSubscription(@NotNull @NotNull RequestContext requestContext, @NotNull @NotNull Asset asset)
protected void performClose()
performClose
in class net.openhft.chronicle.core.io.SimpleCloseable
public void onEndOfSubscription()
BaseSubscriber
onEndOfSubscription
in interface BaseSubscriber
public boolean keyedView()
keyedView
in interface KVSSubscription<K,V>
public void setKvStore(KeyValueStore<K,V> kvStore)
setKvStore
in interface KVSSubscription<K,V>
public void notifyEvent(@NotNull @NotNull MapEvent<K,V> changeEvent)
notifyEvent
in interface EventConsumer<K,V>
notifyEvent
in interface KVSSubscription<K,V>
public int keySubscriberCount()
keySubscriberCount
in interface SubscriptionCollection<MapEvent<K,V>>
public int entrySubscriberCount()
entrySubscriberCount
in interface SubscriptionCollection<MapEvent<K,V>>
public int topicSubscriberCount()
topicSubscriberCount
in interface SubscriptionCollection<MapEvent<K,V>>
public boolean hasSubscribers()
hasSubscribers
in interface KVSSubscription<K,V>
public boolean hasValueSubscribers()
hasValueSubscribers
in interface KVSSubscription<K,V>
public boolean needsPrevious()
needsPrevious
in interface KVSSubscription<K,V>
public void registerSubscriber(@NotNull @NotNull RequestContext rc, @NotNull @NotNull Subscriber<? super MapEvent<K,V>> subscriber, @NotNull @NotNull Filter<? super MapEvent<K,V>> filter)
registerSubscriber
in interface SubscriptionCollection<MapEvent<K,V>>
public void registerKeySubscriber(@NotNull @NotNull RequestContext rc, @NotNull @NotNull Subscriber<? super K> subscriber, @NotNull @NotNull Filter<? super K> filter)
KVSSubscription
registerKeySubscriber
in interface KVSSubscription<K,V>
rc
- RequestContext to usesubscriber
- to addfilter
- a list of filter operationspublic void registerTopicSubscriber(@NotNull @NotNull RequestContext rc, @NotNull @NotNull TopicSubscriber<? super K,? super V> subscriber)
registerTopicSubscriber
in interface KVSSubscription<K,V>
public void registerDownstream(@NotNull @NotNull EventConsumer<K,V> subscription)
registerDownstream
in interface KVSSubscription<K,V>
public void unregisterDownstream(EventConsumer<K,V> subscription)
public void unregisterSubscriber(@NotNull @NotNull Subscriber subscriber)
unregisterSubscriber
in interface SubscriptionCollection<MapEvent<K,V>>
public void unregisterTopicSubscriber(@NotNull @NotNull TopicSubscriber subscriber)
unregisterTopicSubscriber
in interface KVSSubscription<K,V>
Copyright © 2021. All rights reserved.