software.chronicle.datagrid.internal.map.remote

Class RemoteIndexQueueView<K extends net.openhft.chronicle.wire.Marshallable,V extends net.openhft.chronicle.wire.Marshallable>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

net.openhft.chronicle.network.connection.AbstractStatelessClient<MapWireHandler.EventId>

software.chronicle.datagrid.internal.map.remote.RemoteIndexQueueView<K,V>

All Implemented Interfaces:

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

public final class RemoteIndexQueueView<K extends net.openhft.chronicle.wire.Marshallable,V extends net.openhft.chronicle.wire.Marshallable>
extends net.openhft.chronicle.network.connection.AbstractStatelessClient<MapWireHandler.EventId>
implements IndexQueueView<Subscriber<IndexedValue<V>>,V>

Field Summary

Fields inherited from class net.openhft.chronicle.network.connection.AbstractStatelessClient

csp, hub

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

INIT

Constructor Summary

Constructors

Constructor and Description
RemoteIndexQueueView(@NotNull RequestContext context, @NotNull Asset asset)

Method Summary

Modifier and Type	Method and Description
Asset	asset()
void	registerSubscriber(@NotNull Subscriber<IndexedValue<V>> subscriber, @NotNull IndexQuery<V> vanillaIndexQuery)
@Nullable Object	underlying()
void	unregisterSubscriber(@NotNull Subscriber<IndexedValue<V>> listener)

Methods inherited from class net.openhft.chronicle.network.connection.AbstractStatelessClient

attempt, performClose, proxyReturnBoolean, proxyReturnBooleanWithArgs, proxyReturnBooleanWithSequence, proxyReturnByte, proxyReturnByte, proxyReturnInt, proxyReturnInt, proxyReturnLong, proxyReturnLongWithArgs, proxyReturnTypedObject, proxyReturnTypedObject, proxyReturnTypedObject, proxyReturnUint16, proxyReturnVoid, proxyReturnVoid, proxyReturnWireConsumer, proxyReturnWireConsumerInOut, proxyReturnWireTypedObject, readBoolean, readInt, sendBytes, sendEvent, sendEventAsync, toParameters, toParameters, writeMetaDataForKnownTID

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

RemoteIndexQueueView

public RemoteIndexQueueView(@NotNull
                            @NotNull RequestContext context,
                            @NotNull
                            @NotNull Asset asset)

Method Detail

asset

public Asset asset()

Specified by:

asset in interface Assetted<Object>

Returns:

The Asset this resource is associated with.

underlying

@Nullable
public @Nullable Object underlying()

Specified by:

underlying in interface Assetted<Object>

Returns:

The Underlying view this view is built on.

registerSubscriber

public void registerSubscriber(@NotNull
                               @NotNull Subscriber<IndexedValue<V>> subscriber,
                               @NotNull
                               @NotNull IndexQuery<V> vanillaIndexQuery)

Specified by:

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

unregisterSubscriber

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

Specified by:

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