public final class QueueSimpleSubscription<E> extends net.openhft.chronicle.core.io.SimpleCloseable implements SimpleSubscription<E>
Constructor and Description |
---|
QueueSimpleSubscription(Function<Object,E> valueReader,
@NotNull Asset parent,
String topic) |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed
public void registerSubscriber(@NotNull @NotNull RequestContext rc, @NotNull @NotNull Subscriber<? super E> subscriber, @NotNull @NotNull Filter<? super E> filter)
registerSubscriber
in interface SubscriptionCollection<E>
public void registerSubscriber(boolean bootstrap, int throttlePeriodMs, @NotNull @NotNull Subscriber<? super E> subscriber)
public void unregisterSubscriber(@NotNull @NotNull Subscriber subscriber)
unregisterSubscriber
in interface SubscriptionCollection<E>
public int keySubscriberCount()
keySubscriberCount
in interface SubscriptionCollection<E>
public int entrySubscriberCount()
entrySubscriberCount
in interface SubscriptionCollection<E>
public int topicSubscriberCount()
topicSubscriberCount
in interface SubscriptionCollection<E>
public int subscriberCount()
subscriberCount
in interface SubscriptionCollection<E>
public void notifyMessage(Object e)
notifyMessage
in interface SimpleSubscription<E>
protected void performClose()
performClose
in class net.openhft.chronicle.core.io.SimpleCloseable
Copyright © 2021. All rights reserved.