Uses of Class
org.infinispan.loaders.CacheLoaderException

Packages that use CacheLoaderException
org.infinispan.commands.control   
org.infinispan.loaders This package contains loaders and stores, which are used for overflow or persistence. 
org.infinispan.loaders.bdbje This package contains a CacheStore implementation based on Oracle's BDBJE storage engine. 
org.infinispan.loaders.bucket   
org.infinispan.loaders.cluster   
org.infinispan.loaders.decorators This package contains loaders and stores, which are used for overflow or persistence. 
org.infinispan.loaders.file   
org.infinispan.loaders.jdbc This package contains a CacheStore implementation based on a JDBC database connection. 
org.infinispan.loaders.jdbc.binary This JDBC CacheStore implementation is optimized for storing binary (non-String) keys in the cache. 
org.infinispan.loaders.jdbc.connectionfactory Connection factories for use with the JDBC Cache Store. 
org.infinispan.loaders.jdbc.mixed This is a delegating CacheStore implementation that delegates either to a binary or String based JDBC cache store depending on the key used. 
org.infinispan.loaders.jdbc.stringbased This JDBC CacheStore implementation is optimized for storing String keys in the cache. 
org.infinispan.loaders.jdbm This package contains a CacheStore implementation based on persisting to JDBM. 
org.infinispan.loaders.s3 This package contains a CacheStore implementation based on persisting to Amazon's S3 service. 
 

Uses of CacheLoaderException in org.infinispan.commands.control
 

Methods in org.infinispan.commands.control that throw CacheLoaderException
 Map<Object,InternalCacheValue> RehashControlCommand.pullState()
           
 

Uses of CacheLoaderException in org.infinispan.loaders
 

Methods in org.infinispan.loaders that throw CacheLoaderException
protected  void LockSupportCacheStore.acquireGlobalLock(boolean exclusive)
          Based on the supplied param, acquires a global read(false) or write (true) lock.
protected  void AbstractCacheStore.applyModifications(List<? extends Modification> mods)
           
 void LockSupportCacheStore.clear()
           
 void CacheStore.clear()
          Clears all entries in the store
protected abstract  void LockSupportCacheStore.clearLockSafe()
           
 void CacheStore.commit(GlobalTransaction tx)
          Commits a transaction that has been previously prepared.
 void AbstractCacheStore.commit(GlobalTransaction tx)
           
 boolean CacheLoader.containsKey(Object key)
           
 boolean AbstractCacheLoader.containsKey(Object key)
           This implementation delegates to CacheLoader.load(Object), to ensure that a response is returned only if the entry is not expired.
 void LockSupportCacheStore.fromStream(ObjectInput objectInput)
           
 void CacheStore.fromStream(ObjectInput inputStream)
          Writes contents of the stream to the store.
protected abstract  void LockSupportCacheStore.fromStreamLockSafe(ObjectInput ois)
           
protected abstract  String LockSupportCacheStore.getLockFromKey(Object key)
           
protected  boolean LockSupportCacheStore.immediateLockForWriting(String key)
          Same as LockSupportCacheStore.lockForWriting(String), but with 0 timeout.
 void LockSupportCacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
 void CacheLoader.init(CacheLoaderConfig config, Cache cache, Marshaller m)
          Used to initialize a cache loader.
 void AbstractCacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
 InternalCacheEntry LockSupportCacheStore.load(Object key)
           
 InternalCacheEntry CacheLoader.load(Object key)
          Loads an entry mapped to by a given key.
 Set<InternalCacheEntry> LockSupportCacheStore.loadAll()
           
 Set<InternalCacheEntry> CacheLoader.loadAll()
          Loads all entries in the loader.
protected abstract  Set<InternalCacheEntry> LockSupportCacheStore.loadAllLockSafe()
           
protected abstract  InternalCacheEntry LockSupportCacheStore.loadLockSafe(Object key, String lockingKey)
           
protected  void LockSupportCacheStore.lockForReading(String key)
          Acquires read lock on the given key.
protected  void LockSupportCacheStore.lockForWriting(String key)
          Acquires write lock on the given key.
 void CacheStore.prepare(List<? extends Modification> modifications, GlobalTransaction tx, boolean isOnePhase)
          Issues a prepare call with a set of modifications to be applied to the cache store
 void AbstractCacheStore.prepare(List<? extends Modification> mods, GlobalTransaction tx, boolean isOnePhase)
           
 void CacheStore.purgeExpired()
          Purges expired entries from the store.
 void AbstractCacheStore.purgeExpired()
           
protected abstract  void AbstractCacheStore.purgeInternal()
           
 boolean LockSupportCacheStore.remove(Object key)
           
 boolean CacheStore.remove(Object key)
          Removes an entry in the store.
 void CacheStore.removeAll(Set<Object> keys)
          Bulk remove operation
 void AbstractCacheStore.removeAll(Set<Object> keys)
           
protected abstract  boolean LockSupportCacheStore.removeLockSafe(Object key, String lockingKey)
           
protected  void AbstractCacheStore.safeClose(InputStream stream)
           
protected  void AbstractCacheStore.safeClose(OutputStream stream)
           
 void LockSupportCacheStore.start()
           
 void CacheLoader.start()
           
 void AbstractCacheStore.start()
           
 void CacheLoader.stop()
           
 void AbstractCacheStore.stop()
           
 void LockSupportCacheStore.store(InternalCacheEntry ed)
           
 void CacheStore.store(InternalCacheEntry entry)
          Stores an entry
protected abstract  void LockSupportCacheStore.storeLockSafe(InternalCacheEntry ed, String lockingKey)
           
 void LockSupportCacheStore.toStream(ObjectOutput objectOutput)
           
 void CacheStore.toStream(ObjectOutput outputStream)
          Loads the entire state into a stream, using whichever format is most efficient for the cache loader implementation.
protected abstract  void LockSupportCacheStore.toStreamLockSafe(ObjectOutput oos)
           
 

Uses of CacheLoaderException in org.infinispan.loaders.bdbje
 

Methods in org.infinispan.loaders.bdbje that throw CacheLoaderException
protected  void BdbjeCacheStore.applyModifications(List<? extends Modification> mods)
          Perform the mods atomically by creating a worker and invoking them in TransactionRunner.run(com.sleepycat.collections.TransactionWorker).
 void BdbjeCacheStore.clear()
          Clears all entries in the store
 void BdbjeCacheStore.commit(GlobalTransaction tx)
          Commits a transaction that has been previously prepared.
protected  void BdbjeCacheStore.completeTransaction(GlobalTransaction tx, boolean commit)
          Looks up the SleepyCat transaction associated with the parameter tx.
 void BdbjeCacheStore.fromStream(ObjectInput ois)
          Writes contents of the stream to the store.
 void BdbjeCacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
          Used to initialize a cache loader.
 InternalCacheEntry BdbjeCacheStore.load(Object key)
          Loads an entry mapped to by a given key.
 Set<InternalCacheEntry> BdbjeCacheStore.loadAll()
          Loads all entries in the loader.
protected  void BdbjeCacheStore.prepare(List<? extends Modification> mods, GlobalTransaction tx)
          Looks up the SleepyCat transaction associated with tx.
 void BdbjeCacheStore.prepare(List<? extends Modification> mods, GlobalTransaction tx, boolean isOnePhase)
          Issues a prepare call with a set of modifications to be applied to the cache store
protected  void BdbjeCacheStore.purgeInternal()
          Iterate through StoredMap.entrySet() and remove, if expired.
 boolean BdbjeCacheStore.remove(Object key)
          Removes an entry in the store.
 void BdbjeCacheStore.start()
           Validates configuration, configures and opens the Environment, then opens the databases.
 void BdbjeCacheStore.stop()
          Stops transaction and purge processing and closes the SleepyCat environment.
 void BdbjeCacheStore.store(InternalCacheEntry ed)
          Stores an entry
 void BdbjeCacheStore.toStream(ObjectOutput oos)
          Writes the current count of cachestore entries followed by a pair of byte[]s corresponding to the SleepyCat binary representation of key value.
 

Uses of CacheLoaderException in org.infinispan.loaders.bucket
 

Methods in org.infinispan.loaders.bucket that throw CacheLoaderException
protected abstract  void BucketBasedCacheStore.insertBucket(Bucket bucket)
           
protected abstract  Bucket BucketBasedCacheStore.loadBucket(String keyHashCode)
          Loads the bucket from the store, base on the hashcode.
protected  InternalCacheEntry BucketBasedCacheStore.loadLockSafe(Object key, String lockingKey)
          Loads the bucket coresponding to the given key, and lookups the key within it.
protected  boolean BucketBasedCacheStore.removeLockSafe(Object key, String lockingKey)
          Lookups a bucket where the given key is stored.
protected abstract  void BucketBasedCacheStore.saveBucket(Bucket bucket)
          This method assumes that the bucket is already persisted in the database.
protected  void BucketBasedCacheStore.storeLockSafe(InternalCacheEntry ed, String lockingKey)
          Tries to find a bucket corresponding to storedEntry's key, and updates it with the storedEntry.
 

Uses of CacheLoaderException in org.infinispan.loaders.cluster
 

Methods in org.infinispan.loaders.cluster that throw CacheLoaderException
 InternalCacheEntry ClusterCacheLoader.load(Object key)
           
 Set<InternalCacheEntry> ClusterCacheLoader.loadAll()
           
 void ClusterCacheLoader.start()
           
 void ClusterCacheLoader.stop()
           
 

Uses of CacheLoaderException in org.infinispan.loaders.decorators
 

Methods in org.infinispan.loaders.decorators that throw CacheLoaderException
protected  void AsyncStore.applyModificationsSync(ConcurrentMap<Object,Modification> mods)
           
 void SingletonStore.clear()
           
 void ChainingCacheStore.clear()
           
 void AbstractDelegatingStore.clear()
           
 void SingletonStore.commit(GlobalTransaction tx)
           
 void ChainingCacheStore.commit(GlobalTransaction tx)
           
 void AbstractDelegatingStore.commit(GlobalTransaction tx)
           
 boolean ChainingCacheStore.containsKey(Object key)
           
 boolean AbstractDelegatingStore.containsKey(Object key)
           
 void SingletonStore.fromStream(ObjectInput inputStream)
           
 void ChainingCacheStore.fromStream(ObjectInput inputStream)
           
 void AbstractDelegatingStore.fromStream(ObjectInput inputStream)
           
 void ChainingCacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
 void AsyncStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
 void AbstractDelegatingStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
 InternalCacheEntry ChainingCacheStore.load(Object key)
           
 InternalCacheEntry AbstractDelegatingStore.load(Object key)
           
 Set<InternalCacheEntry> ChainingCacheStore.loadAll()
           
 Set<InternalCacheEntry> AbstractDelegatingStore.loadAll()
           
 void SingletonStore.prepare(List<? extends Modification> list, GlobalTransaction tx, boolean isOnePhase)
           
 void ChainingCacheStore.prepare(List<? extends Modification> list, GlobalTransaction tx, boolean isOnePhase)
           
 void AbstractDelegatingStore.prepare(List<? extends Modification> list, GlobalTransaction tx, boolean isOnePhase)
           
 void SingletonStore.purgeExpired()
           
 void ChainingCacheStore.purgeExpired()
           
 void AbstractDelegatingStore.purgeExpired()
           
 void ChainingCacheStore.purgeIfNecessary()
           
 boolean SingletonStore.remove(Object key)
           
 boolean ChainingCacheStore.remove(Object key)
           
 boolean AbstractDelegatingStore.remove(Object key)
           
 void ChainingCacheStore.removeAll(Set<Object> keys)
           
 void AbstractDelegatingStore.removeAll(Set<Object> keys)
           
 void SingletonStore.start()
           
 void ChainingCacheStore.start()
           
 void AsyncStore.start()
           
 void AbstractDelegatingStore.start()
           
 void SingletonStore.stop()
           
 void ChainingCacheStore.stop()
           
 void AsyncStore.stop()
           
 void AbstractDelegatingStore.stop()
           
 void SingletonStore.store(InternalCacheEntry ed)
           
 void ChainingCacheStore.store(InternalCacheEntry ed)
           
 void AbstractDelegatingStore.store(InternalCacheEntry ed)
           
 void ChainingCacheStore.toStream(ObjectOutput outputStream)
           
 void AbstractDelegatingStore.toStream(ObjectOutput outputStream)
           
 

Uses of CacheLoaderException in org.infinispan.loaders.file
 

Methods in org.infinispan.loaders.file that throw CacheLoaderException
protected  void FileCacheStore.clearLockSafe()
           
protected  void FileCacheStore.fromStreamLockSafe(ObjectInput objectInput)
           
 void FileCacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
protected  void FileCacheStore.insertBucket(Bucket bucket)
           
protected  Set<InternalCacheEntry> FileCacheStore.loadAllLockSafe()
           
protected  Bucket FileCacheStore.loadBucket(File bucketFile)
           
protected  Bucket FileCacheStore.loadBucket(String bucketName)
           
 Bucket FileCacheStore.loadBucketContainingKey(String key)
           
protected  void FileCacheStore.purgeInternal()
           
 void FileCacheStore.saveBucket(Bucket b)
           
 void FileCacheStore.start()
           
protected  void FileCacheStore.toStreamLockSafe(ObjectOutput objectOutput)
           
 

Uses of CacheLoaderException in org.infinispan.loaders.jdbc
 

Methods in org.infinispan.loaders.jdbc that throw CacheLoaderException
 void DataManipulationHelper.clear()
           
 void TableManipulation.createTable(Connection conn)
           
 void TableManipulation.dropTable(Connection conn)
           
abstract  boolean DataManipulationHelper.fromStreamProcess(Object objFromStream, PreparedStatement ps, ObjectInput objectInput)
           
 void DataManipulationHelper.fromStreamSupport(ObjectInput objectInput)
           
abstract  void DataManipulationHelper.loadAllProcess(ResultSet rs, Set<InternalCacheEntry> result)
           
 Set<InternalCacheEntry> DataManipulationHelper.loadAllSupport()
           
static void DataManipulationHelper.logAndThrow(Exception e, String message)
           
static ByteBuffer JdbcUtil.marshall(Marshaller marshaller, Object bucket)
           
 void TableManipulation.start(ConnectionFactory connectionFactory)
           
 void TableManipulation.stop()
           
 boolean TableManipulation.tableExists(Connection connection)
           
 boolean TableManipulation.tableExists(Connection connection, String tableName)
           
abstract  void DataManipulationHelper.toStreamProcess(ResultSet rs, InputStream is, ObjectOutput objectOutput)
           
 void DataManipulationHelper.toStreamSupport(ObjectOutput objectOutput, byte streamDelimiter)
           
static Object JdbcUtil.unmarshall(Marshaller marshaller, InputStream inputStream)
           
 

Uses of CacheLoaderException in org.infinispan.loaders.jdbc.binary
 

Methods in org.infinispan.loaders.jdbc.binary that throw CacheLoaderException
protected  void JdbcBinaryCacheStore.clearLockSafe()
           
 void JdbcBinaryCacheStore.doConnectionFactoryInitialization(ConnectionFactory connectionFactory)
          Keeps a reference to the connection factory for further use.
protected  void JdbcBinaryCacheStore.fromStreamLockSafe(ObjectInput objectInput)
           
 void JdbcBinaryCacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
protected  void JdbcBinaryCacheStore.insertBucket(Bucket bucket)
           
 Set<InternalCacheEntry> JdbcBinaryCacheStore.loadAllLockSafe()
           
protected  Bucket JdbcBinaryCacheStore.loadBucket(String keyHashCode)
           
 void JdbcBinaryCacheStore.purgeInternal()
           
protected  void JdbcBinaryCacheStore.saveBucket(Bucket bucket)
           
 void JdbcBinaryCacheStore.start()
           
 void JdbcBinaryCacheStore.stop()
           
protected  void JdbcBinaryCacheStore.toStreamLockSafe(ObjectOutput objectOutput)
           
 

Uses of CacheLoaderException in org.infinispan.loaders.jdbc.connectionfactory
 

Methods in org.infinispan.loaders.jdbc.connectionfactory that throw CacheLoaderException
 Connection SimpleConnectionFactory.getConnection()
           
 Connection PooledConnectionFactory.getConnection()
           
 Connection ManagedConnectionFactory.getConnection()
           
abstract  Connection ConnectionFactory.getConnection()
          Fetches a connection from the factory.
static ConnectionFactory ConnectionFactory.getConnectionFactory(String connectionFactoryClass)
          Constructs a ConnectionFactory based on the supplied class name.
 void SimpleConnectionFactory.start(ConnectionFactoryConfig config)
           
 void PooledConnectionFactory.start(ConnectionFactoryConfig config)
           
 void ManagedConnectionFactory.start(ConnectionFactoryConfig config)
           
abstract  void ConnectionFactory.start(ConnectionFactoryConfig config)
          Starts the connection factory.
 

Uses of CacheLoaderException in org.infinispan.loaders.jdbc.mixed
 

Methods in org.infinispan.loaders.jdbc.mixed that throw CacheLoaderException
 void JdbcMixedCacheStore.clear()
           
 void JdbcMixedCacheStore.fromStream(ObjectInput inputStream)
           
 void JdbcMixedCacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
 InternalCacheEntry JdbcMixedCacheStore.load(Object key)
           
 Set<InternalCacheEntry> JdbcMixedCacheStore.loadAll()
           
protected  void JdbcMixedCacheStore.purgeInternal()
           
 boolean JdbcMixedCacheStore.remove(Object key)
           
 void JdbcMixedCacheStore.start()
           
 void JdbcMixedCacheStore.stop()
           
 void JdbcMixedCacheStore.store(InternalCacheEntry ed)
           
 void JdbcMixedCacheStore.toStream(ObjectOutput outputStream)
           
 

Uses of CacheLoaderException in org.infinispan.loaders.jdbc.stringbased
 

Subclasses of CacheLoaderException in org.infinispan.loaders.jdbc.stringbased
 class UnsupportedKeyTypeException
          Exception thrown by JdbcStringBasedCacheStore when one tries to persist a StoredEntry with an unsupported key type.
 

Methods in org.infinispan.loaders.jdbc.stringbased that throw CacheLoaderException
protected  void JdbcStringBasedCacheStore.clearLockSafe()
           
 void JdbcStringBasedCacheStore.doConnectionFactoryInitialization(ConnectionFactory connectionFactory)
          Keeps a reference to the connection factory for further use.
 void JdbcStringBasedCacheStore.fromStreamLockSafe(ObjectInput objectInput)
           
protected  String JdbcStringBasedCacheStore.getLockFromKey(Object key)
           
 void JdbcStringBasedCacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m)
           
protected  Set<InternalCacheEntry> JdbcStringBasedCacheStore.loadAllLockSafe()
           
protected  InternalCacheEntry JdbcStringBasedCacheStore.loadLockSafe(Object key, String lockingKey)
           
protected  void JdbcStringBasedCacheStore.logAndThrow(Exception e, String message)
           
 void JdbcStringBasedCacheStore.purgeInternal()
           
 boolean JdbcStringBasedCacheStore.removeLockSafe(Object key, String keyStr)
           
 void JdbcStringBasedCacheStore.start()
           
 void JdbcStringBasedCacheStore.stop()
           
 void JdbcStringBasedCacheStore.storeLockSafe(InternalCacheEntry ed, String lockingKey)
           
protected  void JdbcStringBasedCacheStore.toStreamLockSafe(ObjectOutput objectOutput)
           
 

Uses of CacheLoaderException in org.infinispan.loaders.jdbm
 

Methods in org.infinispan.loaders.jdbm that throw CacheLoaderException
protected  void JdbmCacheStore.applyModifications(List<? extends Modification> mods)
           
 void JdbmCacheStore.clear()
           
 void JdbmCacheStore.fromStream(ObjectInput in)
          Reads from a stream the number of entries (long) then the entries themselves.
 void JdbmCacheStore.init(CacheLoaderConfig clc, Cache cache, Marshaller m)
           
 InternalCacheEntry JdbmCacheStore.load(Object key)
           
 Set<InternalCacheEntry> JdbmCacheStore.loadAll()
           
protected  void JdbmCacheStore.purgeInternal()
          Purge expired entries.
 boolean JdbmCacheStore.remove(Object key)
           
 boolean JdbmCacheStore.remove0(Object key)
           
 void JdbmCacheStore.start()
           
 void JdbmCacheStore.store(InternalCacheEntry entry)
           
 void JdbmCacheStore.toStream(ObjectOutput out)
          Writes to a stream the number of entries (long) then the entries themselves.
 

Uses of CacheLoaderException in org.infinispan.loaders.s3
 

Subclasses of CacheLoaderException in org.infinispan.loaders.s3
 class S3ConnectionException
          An exception thrown by a S3Bucket implementation if there are problems reading from S3.
 

Methods in org.infinispan.loaders.s3 that throw CacheLoaderException
protected  void S3CacheStore.clearLockSafe()
           
protected  void S3CacheStore.fromStreamLockSafe(ObjectInput objectInput)
           
 void S3CacheStore.init(CacheLoaderConfig cfg, Cache cache, Marshaller m)
          Used to initialize a cache loader.
 void S3CacheStore.init(CacheLoaderConfig config, Cache cache, Marshaller m, S3Connection connection, S3Bucket bucket)
           
protected  void S3CacheStore.insertBucket(Bucket bucket)
           
protected  Set<InternalCacheEntry> S3CacheStore.loadAllLockSafe()
           
protected  Bucket S3CacheStore.loadBucket(String bucketName)
           
protected  void S3CacheStore.purgeInternal()
           
protected  void S3CacheStore.saveBucket(Bucket bucket)
           
 void S3CacheStore.start()
           
 void S3CacheStore.stop()
           
protected  void S3CacheStore.toStreamLockSafe(ObjectOutput objectOutput)
           
 


Google Analytics

Copyright © 2009 JBoss, a division of Red Hat. All Rights Reserved.