software.chronicle.datagrid.pubsub

Interface SubscriptionCollection<E>

All Superinterfaces:

AutoCloseable, Closeable, net.openhft.chronicle.core.io.QueryCloseable

All Known Subinterfaces:

KVSSubscription<K,V>, ObjectSubscription<K,V>, RawKVSSubscription<K,V>, SimpleSubscription<E>, TopologySubscription

All Known Implementing Classes:

MapKVSSubscription, MapSimpleSubscription, QueueObjectSubscription, QueueSimpleSubscription, RemoteKVSSubscription, RemoteSimpleSubscription, RemoteTopologySubscription, VanillaTopologySubscription

public interface SubscriptionCollection<E>
extends net.openhft.chronicle.core.io.Closeable

Internal API for managing and monitoring subscriptions.

Method Summary

Modifier and Type	Method and Description
int	entrySubscriberCount()
int	keySubscriberCount()
void	registerSubscriber(@NotNull RequestContext rc, @NotNull Subscriber<? super E> subscriber, @NotNull Filter<? super E> filter)
default int	subscriberCount()
int	topicSubscriberCount()
void	unregisterSubscriber(@NotNull Subscriber<? super E> subscriber)

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

Method Detail

registerSubscriber

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

unregisterSubscriber

void unregisterSubscriber(@NotNull
                          @NotNull Subscriber<? super E> subscriber)

keySubscriberCount

int keySubscriberCount()

entrySubscriberCount

int entrySubscriberCount()

topicSubscriberCount

int topicSubscriberCount()

subscriberCount

default int subscriberCount()

Returns:

total subscriber count.