org.teiid.resource.adapter.infinispan.local

Class LocalCacheConnection<K,V>

java.lang.Object

org.teiid.resource.adapter.infinispan.InfinispanCacheWrapper<K,V>

org.teiid.resource.adapter.infinispan.local.LocalCacheConnection<K,V>

Type Parameters:

K -

V -

All Implemented Interfaces:

InfinispanCacheConnection, ObjectConnection

public class LocalCacheConnection<K,V>
extends InfinispanCacheWrapper<K,V>

This wrapper will contain a local Infinispan cache, and will the necessary logic for looking up the cache by jndiName

Author:

vanhalbert

Constructor Summary

Constructors

Constructor and Description
LocalCacheConnection()

Method Summary

Modifier and Type	Method and Description
void	add(Object key, Object value) Call to add an object to the cache
void	cleanUp() Called to enable the connection to cleanup after use
void	clearCache(String cacheName) Called to clear the cache and delete all objects.
Object	get(Object key) Call to obtain an object from the cache based on the specified key
Collection<Object>	getAll() Call to obtain all the objects from the cache
org.infinispan.Cache	getCache() Call to obtain the default cache object
org.infinispan.Cache<Object,Object>	getCache(String cacheName) Call to obtain the cache object based on the provided cacheName;
InfinispanManagedConnectionFactory	getConfig()
org.infinispan.query.dsl.QueryFactory	getQueryFactory() Call to return the QueryFactory that based on the type of Search used.
SearchType	getSearchType() Returns the SearchType that will be used to perform dynamic searching of the cache.
void	init(InfinispanManagedConnectionFactory config) Called so the wrapper, with the configuration, can create the cache manager it will use
void	init(InfinispanManagedConnectionFactory config, Object cacheManager) Called to pass in the cacheManager it will use.
boolean	isAlive() Call to check the status of the connection
protected Object	performJNDICacheLookup(String jndiName)
Object	remove(Object key) Call to remove an object from the cache
protected void	shutDownCacheManager() Note: This is used in testing only to enable shutting down the cache so that the next test can recreate it Provided for testing purposes
void	update(Object key, Object value) Call to update an object in the cache

Methods inherited from class org.teiid.resource.adapter.infinispan.InfinispanCacheWrapper

getCacheClassType, getCacheKeyClassType, getCacheName, getClassRegistry, getMaterializeLifeCycle, getPkField

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalCacheConnection

public LocalCacheConnection()

Method Detail

getConfig

public InfinispanManagedConnectionFactory getConfig()

Specified by:

getConfig in class InfinispanCacheWrapper<K,V>

init

public void init(InfinispanManagedConnectionFactory config,
                 Object cacheManager)

Description copied from class: InfinispanCacheWrapper

Called to pass in the cacheManager it will use. This will be called when the CacheManager was registered via JNDI. The factory makes the determination if its a local or remote cache and initializes the wrapper accordingly.

Specified by:

init in class InfinispanCacheWrapper<K,V>

cacheManager - object

init

public void init(InfinispanManagedConnectionFactory config)
          throws javax.resource.ResourceException

Description copied from class: InfinispanCacheWrapper

Called so the wrapper, with the configuration, can create the cache manager it will use

Specified by:

init in class InfinispanCacheWrapper<K,V>

Throws:

javax.resource.ResourceException

isAlive

public boolean isAlive()

Call to check the status of the connection

Returns:

boolean true if the connection is alive.

See Also:

ObjectConnection.isAlive()

getCache

public org.infinispan.Cache getCache()

Call to obtain the default cache object

Returns:

Map object cache

See Also:

ObjectConnection.getCache()

getCache

public org.infinispan.Cache<Object,Object> getCache(String cacheName)

Call to obtain the cache object based on the provided cacheName;

Returns:

Map object cache

See Also:

ObjectConnection.getCache(java.lang.String)

getAll

public Collection<Object> getAll()

Call to obtain all the objects from the cache

Returns:

List of all the objects in the cache

See Also:

ObjectConnection.getAll()

performJNDICacheLookup

protected Object performJNDICacheLookup(String jndiName)
                                 throws Exception

Throws:

Exception

cleanUp

public void cleanUp()

Called to enable the connection to cleanup after use

See Also:

ObjectConnection.cleanUp()

getQueryFactory

public org.infinispan.query.dsl.QueryFactory getQueryFactory()

Call to return the QueryFactory that based on the type of Search used.

Returns:

QueryFactory

See Also:

InfinispanCacheConnection.getQueryFactory()

get

public Object get(Object key)

Call to obtain an object from the cache based on the specified key

Parameters:

key - to use to get the object from the cache

Returns:

Object

See Also:

ObjectConnection.get(java.lang.Object)

add

public void add(Object key,
                Object value)

Call to add an object to the cache

See Also:

ObjectConnection.add(java.lang.Object, java.lang.Object)

remove

public Object remove(Object key)

Call to remove an object from the cache

Returns:

Object that was removed

See Also:

ObjectConnection.remove(java.lang.Object)

update

public void update(Object key,
                   Object value)

Call to update an object in the cache

See Also:

ObjectConnection.update(java.lang.Object, java.lang.Object)

clearCache

public void clearCache(String cacheName)
                throws TranslatorException

Called to clear the cache and delete all objects.

Throws:

TranslatorException

See Also:

ObjectConnection.clearCache(java.lang.String)

shutDownCacheManager

protected void shutDownCacheManager()

Note: This is used in testing only to enable shutting down the cache so that the next test can recreate it Provided for testing purposes

Specified by:

shutDownCacheManager in class InfinispanCacheWrapper<K,V>

See Also:

InfinispanCacheWrapper.shutDownCacheManager()

getSearchType

public SearchType getSearchType()

Returns the SearchType that will be used to perform dynamic searching of the cache.

Returns:

SearchType