org.rvpf.store.client

Class AbstractSink

Object

Proxied.Abstract

AbstractStore

AbstractSink

All Implemented Interfaces:

Comparable<Store>, Store, Proxied

Direct Known Subclasses:

NullStore, RMISink, SOMSink

public abstract class AbstractSink
extends AbstractStore

Abstract sink.

Nested Class Summary

Nested classes/interfaces inherited from interface Proxied

Proxied.Abstract

Field Summary

Fields inherited from class AbstractStore

QUERIES_BATCH_LIMIT_PROPERTY, RESPONSE_LIMIT_PROPERTY

Fields inherited from interface Store

ARCHIVE_TIME_PARAM, BIND_POINTS_PARAM, BINDING_PARAM, CONFIRM_PARAM, CONFIRM_RETRIES_PARAM, CONFIRM_RETRY_DELAY_PARAM, DEFAULT_STORE_NAME, LIFE_TIME_PARAM, NAME_PARAM, NULL_REMOVES_PARAM, PASSWORD_PARAM, QUEUE_PARAM, RESPECT_VERSION_PARAM, SECURITY_PARAM, USER_PARAM

Constructor Summary

Constructors

Constructor and Description
AbstractSink()

Method Summary

Modifier and Type	Method and Description
Optional<StoreValues>	nextValues() Returns the next store values to our store queries.
StoreValues	select(StoreValuesQuery query) Selects the store values for a store query.
boolean	supportsCount() Asks if this store supports count.

Methods inherited from class AbstractStore

accessException, addQuery, addUpdate, bind, bindPoints, bindPoints, canConfirm, close, compareTo, confirm, deliver, doAddQuery, getConfirmRetries, getConfirmRetryDelay, getQueriesBatchLimit, getResponseLimit, getSubscribedValues, getThisLogger, getUpdateCount, getUpdates, getUUID, impersonate, isNullRemoves, iterate, pull, purge, reset, sendUpdates, setConfirmRetries, setQueriesBatchLimit, setResponseLimit, setUp, subscribe, subscribe, supportedValueTypeCodes, supportedValueTypes, supportsDelete, supportsDeliver, supportsPull, supportsPurge, supportsSubscribe, tearDown, unsubscribe

Methods inherited from class Proxied.Abstract

getMetadata, getName, getParams, getProxyEntity

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Store

connect, getExceptions, getName, getParams, probe, sendUpdates

Constructor Detail

AbstractSink

public AbstractSink()

Method Detail

nextValues

public Optional<StoreValues> nextValues()

Returns the next store values to our store queries.

Any pending query is first sent.

Returns:

The next store values or empty when done.

select

public StoreValues select(StoreValuesQuery query)
                   throws InterruptedException,
                          StoreAccessException

Selects the store values for a store query.

The processing of the query must not interfere with the batch operation mode.

Parameters:

query - The store query.

Returns:

The store values.

Throws:

InterruptedException - When the service is stopped.

StoreAccessException - On store access problem.

supportsCount

public boolean supportsCount()

Asks if this store supports count.

Specified by:

supportsCount in interface Store

Overrides:

supportsCount in class AbstractStore

Returns:

True if count is supported.