software.chronicle.datagrid.internal.pubsub

Class QueueSimpleSubscription<E>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

software.chronicle.datagrid.internal.pubsub.QueueSimpleSubscription<E>

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.ManagedCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, SimpleSubscription<E>, SubscriptionCollection<E>

public final class QueueSimpleSubscription<E>
extends net.openhft.chronicle.core.io.SimpleCloseable
implements SimpleSubscription<E>

Field Summary

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

INIT

Constructor Summary

Constructors

Constructor and Description
QueueSimpleSubscription(Function<Object,E> valueReader, @NotNull Asset parent, String topic)

Method Summary

Modifier and Type	Method and Description
int	entrySubscriberCount()
int	keySubscriberCount()
void	notifyMessage(Object e)
protected void	performClose()
void	registerSubscriber(boolean bootstrap, int throttlePeriodMs, @NotNull Subscriber<? super E> subscriber)
void	registerSubscriber(@NotNull RequestContext rc, @NotNull Subscriber<? super E> subscriber, @NotNull Filter<? super E> filter)
int	subscriberCount()
int	topicSubscriberCount()
void	unregisterSubscriber(@NotNull Subscriber 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 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

QueueSimpleSubscription

public QueueSimpleSubscription(Function<Object,E> valueReader,
                               @NotNull
                               @NotNull Asset parent,
                               String topic)

Method Detail

registerSubscriber

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

Specified by:

registerSubscriber in interface SubscriptionCollection<E>

registerSubscriber

public void registerSubscriber(boolean bootstrap,
                               int throttlePeriodMs,
                               @NotNull
                               @NotNull Subscriber<? super E> subscriber)

unregisterSubscriber

public void unregisterSubscriber(@NotNull
                                 @NotNull Subscriber subscriber)

Specified by:

unregisterSubscriber in interface SubscriptionCollection<E>

keySubscriberCount

public int keySubscriberCount()

Specified by:

keySubscriberCount in interface SubscriptionCollection<E>

entrySubscriberCount

public int entrySubscriberCount()

Specified by:

entrySubscriberCount in interface SubscriptionCollection<E>

topicSubscriberCount

public int topicSubscriberCount()

Specified by:

topicSubscriberCount in interface SubscriptionCollection<E>

subscriberCount

public int subscriberCount()

Specified by:

subscriberCount in interface SubscriptionCollection<E>

Returns:

total subscriber count.

notifyMessage

public void notifyMessage(Object e)

Specified by:

notifyMessage in interface SimpleSubscription<E>

performClose

protected void performClose()

Overrides:

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