org.teiid.resource.adapter.infinispan.base

Class AbstractInfinispanManagedConnectionFactory

java.lang.Object

org.teiid.resource.spi.BasicManagedConnectionFactory

org.teiid.resource.adapter.infinispan.base.AbstractInfinispanManagedConnectionFactory

All Implemented Interfaces:

Serializable, javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ResourceAdapterAssociation, javax.resource.spi.ValidatingManagedConnectionFactory

Direct Known Subclasses:

InfinispanManagedConnectionFactory

public abstract class AbstractInfinispanManagedConnectionFactory
extends BasicManagedConnectionFactory

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractInfinispanManagedConnectionFactory.LocalCacheWrapper

Constructor Summary

Constructors

Constructor and Description
AbstractInfinispanManagedConnectionFactory()

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanUp()
protected void	createCacheContainer()
BasicConnectionFactory<InfinispanConnectionImpl>	createConnectionFactory()
protected abstract CacheContainerWrapper	createRemoteCache(Properties props, ClassLoader classLoader)
boolean	equals(Object obj)
CacheContainerWrapper	getCacheContainer()
String	getCacheJndiName() Get the JNDI Name of the cache.
Map<String,Class<?>>	getCacheNameClassTypeMapping()
Class<?>	getCacheType(String cacheName)
String	getCacheTypeMap() Get the cacheName:ClassName[,cacheName:ClassName...] cache type mappings.
String	getConfigurationFileNameForLocalCache() Get the name of the configuration resource or file that should be used to configure a local EmbeddedCacheManager using DefaultCacheManager.
String	getHotRodClientPropertiesFile() Get the name of the HotRod client properties file that should be used to configure a RemoteCacheManager remoteCacheManager.
String	getModule() Called to get the module(s) that are to be loaded
String	getPkMap(String cacheName)
String	getRemoteServerList() Returns the host:port[;host:port...] list that identifies the remote servers to include in this cluster;
int	hashCode()
protected boolean	isAlive()
protected ClassLoader	loadClasses()
protected Object	performJNDICacheLookup(String jndiName)
void	setCacheJndiName(String jndiName) Set the JNDI name to a cache instance that should be used as this source.
void	setCacheNameClassTypeMapping(Map<String,Class<?>> cacheType)
void	setCacheTypeMap(String cacheTypeMap) Set the cache type mapping cacheName:ClassName[,cacheName:ClassName...] that represent the root node class type for 1 or more caches available for access.
void	setConfigurationFileNameForLocalCache(String configurationFileName) Set the name of the configuration that should be used to configure a local cache .
void	setHotRodClientPropertiesFile(String propertieFileName) Set the name of the HotRod client properties file that should be used to configure a remoteCacheManager.
void	setModule(String module) Sets the (optional) module(s) where the ClassName class is defined, that will be loaded (module,[module,..])
void	setPkMap(Map<String,String> mapOfPKs)
void	setRemoteServerList(String remoteServerList) Set the list of remote servers that make up the Infinispan cluster.

Methods inherited from class org.teiid.resource.spi.BasicManagedConnectionFactory

checkEquals, createConnectionFactory, createManagedConnection, getInstance, getInvalidConnections, getLogWriter, getResourceAdapter, matchManagedConnections, setLogWriter, setResourceAdapter

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractInfinispanManagedConnectionFactory

public AbstractInfinispanManagedConnectionFactory()

Method Detail

createConnectionFactory

public BasicConnectionFactory<InfinispanConnectionImpl> createConnectionFactory()
                                                                         throws javax.resource.ResourceException

Specified by:

createConnectionFactory in interface javax.resource.spi.ManagedConnectionFactory

Specified by:

createConnectionFactory in class BasicManagedConnectionFactory

Throws:

javax.resource.ResourceException

getCacheTypeMap

public String getCacheTypeMap()

Get the cacheName:ClassName[,cacheName:ClassName...] cache type mappings.

Returns:

cacheName:ClassName[,cacheName:ClassName...] cache type mappings

See Also:

setCacheTypeMap(String)

setCacheTypeMap

public void setCacheTypeMap(String cacheTypeMap)

Set the cache type mapping cacheName:ClassName[,cacheName:ClassName...] that represent the root node class type for 1 or more caches available for access.

Parameters:

cacheTypeMap - the cache type mappings passed in the form of cacheName:ClassName[,cacheName:ClassName...]

See Also:

getCacheTypeMap()

setModule

public void setModule(String module)

Sets the (optional) module(s) where the ClassName class is defined, that will be loaded (module,[module,..])

Parameters:

module -

See Also:

getModule()

getModule

public String getModule()

Called to get the module(s) that are to be loaded

Returns:

See Also:

setModule(java.lang.String)

getPkMap

public String getPkMap(String cacheName)

setPkMap

public void setPkMap(Map<String,String> mapOfPKs)

getCacheNameClassTypeMapping

public Map<String,Class<?>> getCacheNameClassTypeMapping()

setCacheNameClassTypeMapping

public void setCacheNameClassTypeMapping(Map<String,Class<?>> cacheType)

getCacheType

public Class<?> getCacheType(String cacheName)

getRemoteServerList

public String getRemoteServerList()

Returns the host:port[;host:port...] list that identifies the remote servers to include in this cluster;

Returns:

host:port[;host:port...] list

setRemoteServerList

public void setRemoteServerList(String remoteServerList)

Set the list of remote servers that make up the Infinispan cluster. The servers must be Infinispan HotRod servers. The list must be in the appropriate format of host:port[;host:port...] that would be used when defining an Infinispan RemoteCacheManager instance. If the value is missing, localhost:11311 is assumed.

Parameters:

remoteServerList - the server list in appropriate server:port;server2:port2 format.

getConfigurationFileNameForLocalCache

public String getConfigurationFileNameForLocalCache()

Get the name of the configuration resource or file that should be used to configure a local EmbeddedCacheManager using DefaultCacheManager.

Returns:

the name of the resource or file configuration that should be passed to the cache container

See Also:

setConfigurationFileNameForLocalCache(String)

setConfigurationFileNameForLocalCache

public void setConfigurationFileNameForLocalCache(String configurationFileName)

Set the name of the configuration that should be used to configure a local cache .

Parameters:

configurationFileName - the name of the configuration file that should be used to load the cacheContainer

See Also:

getConfigurationFileNameForLocalCache()

getHotRodClientPropertiesFile

public String getHotRodClientPropertiesFile()

Get the name of the HotRod client properties file that should be used to configure a RemoteCacheManager remoteCacheManager.

Returns:

the name of the HotRod client properties file to be used to configure RemoteCacheContainer

See Also:

setHotRodClientPropertiesFile(String)

setHotRodClientPropertiesFile

public void setHotRodClientPropertiesFile(String propertieFileName)

Set the name of the HotRod client properties file that should be used to configure a remoteCacheManager.

Parameters:

propertieFileName - the name of the HotRod client properties file that should be used to configure the remote container.

See Also:

getHotRodClientPropertiesFile()

getCacheJndiName

public String getCacheJndiName()

Get the JNDI Name of the cache.

Returns:

JNDI Name of cache

setCacheJndiName

public void setCacheJndiName(String jndiName)

Set the JNDI name to a cache instance that should be used as this source.

Parameters:

jndiName - the JNDI name of the cache instance that should be used

See Also:

setCacheJndiName(String)

getCacheContainer

public CacheContainerWrapper getCacheContainer()

isAlive

protected boolean isAlive()

loadClasses

protected ClassLoader loadClasses()
                           throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

createCacheContainer

protected void createCacheContainer()
                             throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

createRemoteCache

protected abstract CacheContainerWrapper createRemoteCache(Properties props,
                                      ClassLoader classLoader)
                                                    throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

performJNDICacheLookup

protected Object performJNDICacheLookup(String jndiName)
                                 throws Exception

Throws:

Exception

hashCode

public int hashCode()

Specified by:

hashCode in interface javax.resource.spi.ManagedConnectionFactory

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Specified by:

equals in interface javax.resource.spi.ManagedConnectionFactory

Overrides:

equals in class Object

cleanUp

public void cleanUp()