public final class RMISink extends AbstractSink
This class provides a client side access to a RMI Sink.
Proxied.Abstract
QUERIES_BATCH_LIMIT_PROPERTY, RESPONSE_LIMIT_PROPERTY
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 and Description |
---|
RMISink() |
Modifier and Type | Method and Description |
---|---|
protected void |
bindPoints(Set<Point> points)
Binds points to their UUID.
|
void |
connect()
Connects.
|
protected void |
doAddQuery(StoreValuesQuery query)
Does add a store query for point values.
|
Optional<Exception[]> |
getExceptions()
Gets the exceptions.
|
boolean |
probe()
Probes the state of the store session.
|
boolean |
sendUpdates(Collection<PointValue> updates)
Sends updates.
|
boolean |
setUp(Metadata metadata,
ProxyEntity proxyEntity)
Sets up the instance for action.
|
protected String |
supportedValueTypeCodes()
Returns a string of supported value type codes.
|
boolean |
supportsDelete()
Asks if this store supports delete.
|
void |
tearDown()
Tears down what has been set up.
|
nextValues, select, supportsCount
accessException, addQuery, addUpdate, bind, bindPoints, canConfirm, close, compareTo, confirm, deliver, getConfirmRetries, getConfirmRetryDelay, getQueriesBatchLimit, getResponseLimit, getSubscribedValues, getThisLogger, getUpdateCount, getUpdates, getUUID, impersonate, isNullRemoves, iterate, pull, purge, reset, sendUpdates, setConfirmRetries, setQueriesBatchLimit, setResponseLimit, subscribe, subscribe, supportedValueTypes, supportsDeliver, supportsPull, supportsPurge, supportsSubscribe, unsubscribe
getMetadata, getName, getParams, getProxyEntity
public void connect() throws StoreAccessException
StoreAccessException
- On store access problem.public Optional<Exception[]> getExceptions()
public boolean probe() throws StoreAccessException
StoreAccessException
- On store access problem.public boolean sendUpdates(Collection<PointValue> updates) throws StoreAccessException
updates
- The updates to send.StoreAccessException
- On store access problem.public boolean setUp(Metadata metadata, ProxyEntity proxyEntity)
setUp
in interface Proxied
setUp
in class AbstractStore
metadata
- The metadata available to the current process.proxyEntity
- The proxy entity refering to the proxied.public boolean supportsDelete() throws StoreAccessException
supportsDelete
in interface Store
supportsDelete
in class AbstractStore
StoreAccessException
- On store access problem.public void tearDown()
tearDown
in interface Proxied
tearDown
in class AbstractStore
protected void bindPoints(Set<Point> points) throws InterruptedException, StoreAccessException
bindPoints
in class AbstractStore
points
- The points.InterruptedException
- When the service is stopped.StoreAccessException
- On store access problem.protected void doAddQuery(StoreValuesQuery query)
This provides the subclass specific implementation.
doAddQuery
in class AbstractStore
query
- The store query.protected String supportedValueTypeCodes() throws StoreAccessException
supportedValueTypeCodes
in class AbstractStore
StoreAccessException
- On store access problem.Copyright © 2003-2019 Serge Brisson. All Rights Reserved.