public final class SOMSink extends AbstractSink
This class provides a client side access to a sink's SOM queue.
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 |
---|
SOMSink() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the store.
|
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.
|
nextValues, select, supportsCount
accessException, addQuery, addUpdate, bind, bindPoints, bindPoints, canConfirm, 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, supportsDelete, supportsDeliver, supportsPull, supportsPurge, supportsSubscribe, tearDown, unsubscribe
getMetadata, getName, getParams, getProxyEntity
public void close()
May be called redundantly.
close
in interface Store
close
in class AbstractStore
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.protected void doAddQuery(StoreValuesQuery query)
This provides the subclass specific implementation.
doAddQuery
in class AbstractStore
query
- The store query.protected String supportedValueTypeCodes()
supportedValueTypeCodes
in class AbstractStore
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.