software.chronicle.datagrid.internal.query

Class VanillaIndexQueueView<V extends net.openhft.chronicle.wire.Marshallable>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

software.chronicle.datagrid.internal.query.VanillaIndexQueueView<V>

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, IndexQueueView<ConsumingSubscriber<IndexedValue<V>>,V>, Assetted<Object>

public final class VanillaIndexQueueView<V extends net.openhft.chronicle.wire.Marshallable>
extends net.openhft.chronicle.core.io.SimpleCloseable
implements IndexQueueView<ConsumingSubscriber<IndexedValue<V>>,V>

Field Summary

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

INIT

Constructor Summary

Constructors

Constructor and Description
VanillaIndexQueueView(@NotNull RequestContext context, @NotNull Asset asset, @NotNull QueueView<?,V> queueView)

Method Summary

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)

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 software.chronicle.datagrid.query.IndexQueueView

isClosed

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

isClosing, throwExceptionIfClosed

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

referenceId, referenceName, temporary

Constructor Detail

VanillaIndexQueueView

public VanillaIndexQueueView(@NotNull
                             @NotNull RequestContext context,
                             @NotNull
                             @NotNull Asset asset,
                             @NotNull
                             @NotNull QueueView<?,V> queueView)

Method Detail

asset

public Asset asset()

Specified by:

asset in interface Assetted<Object>

Returns:

The Asset this resource is associated with.

underlying

@NotNull
public @NotNull ChronicleQueueView<?,V> underlying()

Specified by:

underlying in interface Assetted<Object>

Returns:

The Underlying view this view is built on.

registerSubscriber

public void registerSubscriber(@NotNull
                               @NotNull ConsumingSubscriber<IndexedValue<V>> sub,
                               @NotNull
                               @NotNull IndexQuery<V> vanillaIndexQuery)

consumers wire on the NIO socket thread

Specified by:

registerSubscriber in interface IndexQueueView<ConsumingSubscriber<IndexedValue<V extends net.openhft.chronicle.wire.Marshallable>>,V extends net.openhft.chronicle.wire.Marshallable>

Parameters:

sub - called when ever there is a subscription event that passes the predicate defined by vanillaIndexQuery

vanillaIndexQuery - the predicate of the subscription

unregisterSubscriber

public void unregisterSubscriber(@NotNull
                                 @NotNull ConsumingSubscriber<IndexedValue<V>> listener)

Specified by:

unregisterSubscriber in interface IndexQueueView<ConsumingSubscriber<IndexedValue<V extends net.openhft.chronicle.wire.Marshallable>>,V extends net.openhft.chronicle.wire.Marshallable>

performClose

protected void performClose()

Overrides:

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