public final class VanillaIndexQueueView<V extends net.openhft.chronicle.wire.Marshallable> extends net.openhft.chronicle.core.io.SimpleCloseable implements IndexQueueView<ConsumingSubscriber<IndexedValue<V>>,V>
Constructor and Description |
---|
VanillaIndexQueueView(@NotNull RequestContext context,
@NotNull Asset asset,
@NotNull QueueView<?,V> queueView) |
Modifier and Type | Method and Description |
---|---|
Asset |
asset() |
protected void |
performClose() |
void |
registerSubscriber(@NotNull ConsumingSubscriber<IndexedValue<V>> sub,
@NotNull IndexQuery<V> vanillaIndexQuery)
consumers wire on the NIO socket thread
|
@NotNull ChronicleQueueView<?,V> |
underlying() |
void |
unregisterSubscriber(@NotNull ConsumingSubscriber<IndexedValue<V>> listener) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isClosed
close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed
public VanillaIndexQueueView(@NotNull @NotNull RequestContext context, @NotNull @NotNull Asset asset, @NotNull @NotNull QueueView<?,V> queueView)
public Asset asset()
@NotNull public @NotNull ChronicleQueueView<?,V> underlying()
underlying
in interface Assetted<Object>
public void registerSubscriber(@NotNull @NotNull ConsumingSubscriber<IndexedValue<V>> sub, @NotNull @NotNull IndexQuery<V> vanillaIndexQuery)
registerSubscriber
in interface IndexQueueView<ConsumingSubscriber<IndexedValue<V extends net.openhft.chronicle.wire.Marshallable>>,V extends net.openhft.chronicle.wire.Marshallable>
sub
- called when ever there is a subscription event that passes the
predicate defined by vanillaIndexQuery
vanillaIndexQuery
- the predicate of the subscriptionpublic void unregisterSubscriber(@NotNull @NotNull ConsumingSubscriber<IndexedValue<V>> listener)
unregisterSubscriber
in interface IndexQueueView<ConsumingSubscriber<IndexedValue<V extends net.openhft.chronicle.wire.Marshallable>>,V extends net.openhft.chronicle.wire.Marshallable>
protected void performClose()
performClose
in class net.openhft.chronicle.core.io.SimpleCloseable
Copyright © 2021. All rights reserved.