public abstract class AbstractNotifyingSail extends AbstractSail implements NotifyingSail
NotifyingSail implementation that takes care of common sail tasks, including proper closing of active
connections and a grace period for active connections during shutdown of the store.connectionTimeOut, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_ITERATION_SYNC_THRESHOLD, initializationLock| Constructor and Description |
|---|
AbstractNotifyingSail() |
| Modifier and Type | Method and Description |
|---|---|
void |
addSailChangedListener(SailChangedListener listener)
Adds the specified SailChangedListener to receive events when the data in this Sail object changes.
|
NotifyingSailConnection |
getConnection()
Opens a connection on the Sail which can be used to query and update data.
|
protected abstract NotifyingSailConnection |
getConnectionInternal()
Returns a store-specific SailConnection object.
|
void |
notifySailChanged(SailChangedEvent event)
Notifies all registered SailChangedListener's of changes to the contents of this Sail.
|
void |
removeSailChangedListener(SailChangedListener listener)
Removes the specified SailChangedListener so that it no longer receives events from this Sail object.
|
addSupportedIsolationLevel, connectionClosed, debugEnabled, getDataDir, getDefaultIsolationLevel, getIterationCacheSyncThreshold, getSupportedIsolationLevels, init, initialize, initializeInternal, isInitialized, isTrackResultSize, removeSupportedIsolationLevel, setConnectionTimeOut, setDataDir, setDefaultIsolationLevel, setIterationCacheSyncThreshold, setSupportedIsolationLevels, setSupportedIsolationLevels, setTrackResultSize, shutDown, shutDownInternal, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetDataDir, getDefaultIsolationLevel, getSupportedIsolationLevels, getValueFactory, init, initialize, isWritable, setDataDir, shutDownpublic NotifyingSailConnection getConnection() throws SailException
SailgetConnection in interface NotifyingSailgetConnection in interface SailgetConnection in class AbstractSailSailException - If no transaction could be started, for example because the Sail is not writable.protected abstract NotifyingSailConnection getConnectionInternal() throws SailException
AbstractSailgetConnectionInternal in class AbstractSailSailExceptionpublic void addSailChangedListener(SailChangedListener listener)
NotifyingSailaddSailChangedListener in interface NotifyingSailpublic void removeSailChangedListener(SailChangedListener listener)
NotifyingSailremoveSailChangedListener in interface NotifyingSailpublic void notifySailChanged(SailChangedEvent event)
Copyright © 2015-2020 Eclipse Foundation. All Rights Reserved.