protected static class LocalHistorianProvider.SyncSFEngineStore extends com.inductiveautomation.ignition.gateway.history.DefaultStoreAndForwardEngine implements DataStore
consumer, dataSink, dataStore, log, shutdown, started, WAIT_TIME
LOG_NAME_TEMPLATE
Constructor and Description |
---|
SyncSFEngineStore(DataStore memory,
DataStore local,
long forwardAge,
int forwardCount) |
Modifier and Type | Method and Description |
---|---|
void |
addDataCountChangeListener(java.beans.PropertyChangeListener listener)
Listener will be notified when new data is available for storage.
|
int |
getDataCount()
Amount of data in the cache available to be forwarded.
|
long |
getOldestTimestamp()
Gets the timestamp of the oldest data, in order to calculate how long
data has been present.
|
void |
removeDataCountChangeListener(java.beans.PropertyChangeListener listener) |
TransactionSet |
takeNext(boolean wait,
int desiredTransactionSize,
java.util.Date olderThan)
Gets the next set of transactions to run.
|
acceptsData, createForwarder, getInfo, getLogger, getPipelineName, getQuarantineManager, getSink, getStore, isAccepting, isLicensedFor, isStarted, setForwardAge, setForwardCount, setForwardSchedule, setPipelineName, setSink, setStore, shutdown, startup, storeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getInfo, getLogName, getPipelineName, getQuarantineManager, isAccepting, shutdown, startup
acceptsData, isLicensedFor, storeData
public void addDataCountChangeListener(java.beans.PropertyChangeListener listener)
DataStore
addDataCountChangeListener
in interface DataStore
public void removeDataCountChangeListener(java.beans.PropertyChangeListener listener)
removeDataCountChangeListener
in interface DataStore
public int getDataCount()
DataStore
getDataCount
in interface DataStore
public long getOldestTimestamp()
DataStore
getOldestTimestamp
in interface DataStore
public TransactionSet takeNext(boolean wait, int desiredTransactionSize, java.util.Date olderThan) throws java.lang.InterruptedException
DataStore
takeNext
in interface DataStore
wait
- whether to block until data is available. If false, or if an
olderThan parameter is provided, will return null if
no data is present.desiredTransactionSize
- the desired size of data in the transactions. ONLY A HINT!
Stores are free to return whatever they think is best. If -1,
it's left to the store's discretion (usually will return 1 at
a time)olderThan
- If null, not used. Otherwise only returns data older than the
given value. Returns null if there is no old data available.java.lang.InterruptedException