org.teiid.resource.adapter.infinispan.hotrod

Class InfinispanManagedConnectionFactory

java.lang.Object

org.teiid.resource.spi.BasicManagedConnectionFactory

org.teiid.resource.adapter.infinispan.hotrod.InfinispanManagedConnectionFactory

All Implemented Interfaces:

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

public class InfinispanManagedConnectionFactory
extends BasicManagedConnectionFactory

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static org.teiid.core.BundleUtil	UTIL

Constructor Summary

Constructors

Constructor and Description
InfinispanManagedConnectionFactory()

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
boolean	configuredUsingAnnotations()
protected void	createCacheContainer()
BasicConnectionFactory<InfinispanConnectionImpl>	createConnectionFactory()
protected org.infinispan.client.hotrod.RemoteCacheManager	createRemoteCacheFromProperties(ClassLoader classLoader)
protected org.infinispan.client.hotrod.RemoteCacheManager	createRemoteCacheFromServerList(ClassLoader classLoader)
boolean	equals(Object obj)
protected String	getAliasCacheName()
org.infinispan.client.hotrod.RemoteCache	getCache(String cacheName)
Class<?>	getCacheClassType() Return the Class that identifies the cache object
org.infinispan.client.hotrod.RemoteCacheManager	getCacheContainer()
String	getCacheJndiName() Get the JNDI Name of the cache.
Class<?>	getCacheKeyClassType() This is an optional argument when defining the CacheTypeMap on the resouce adapter.
String	getCacheName()
CacheNameProxy	getCacheNameProxy()
InfinispanSchemaDefinition	getCacheSchemaConfigurator()
String	getCacheStagingName()
String	getCacheTypeMap() Get the cacheName:className[;pkFieldName[:cacheJavaType]] cache type mappings.
ClassLoader	getClassLoader()
ClassRegistry	getClassRegistry()
org.infinispan.protostream.SerializationContext	getContext()
String	getHotRodClientPropertiesFile() Get the name of the HotRod client properties file that should be used to configure a remoteCacheManager.
String	getMessageDescriptor() Get the Message descriptor class name for the root object in cache
String	getMessageMarshallers() Get the Message Marshaller class names
String	getModule() Called to get the module(s) that are to be loaded
String	getPk()
String	getProtobufDefinitionFile() Get the Protobuf Definition File Name
String	getRemoteServerList() Returns the host:port[;host:port...] list that identifies the remote servers to include in this cluster;
String	getStagingCacheName()
Version	getVersion()
int	hashCode()
boolean	isAlive()
Class<?>	loadClass(String className)
protected ClassLoader	loadClasses()
protected void	registerWithCacheManager()
protected void	setAliasCacheName(String cacheName) An option to configure the alias cache name to use when using JDG to materialize data.
void	setCacheClassTypeClass(Class<?> classCacheType)
protected void	setCacheContainer(org.infinispan.client.hotrod.RemoteCacheManager rcm)
void	setCacheJndiName(String jndiName) Set the JNDI name to a cache instance that should be used as this source.
protected void	setCacheName(String cacheName) Call to set the name of the cache to access when calling getCache
void	setCacheTypeMap(String cacheTypeMap) Set the cache type mapping cacheName:className[;pkFieldName[:cacheJavaType]] that represent the root node class type for an available cache for access.
void	setHotRodClientPropertiesFile(String propertieFileName) Set the name of the HotRod client properties file that should be used to configure a remoteCacheManager.
void	setMessageDescriptor(String messageDescriptor) Set the name of the Message Descriptor
void	setMessageMarshallers(String messageMarshallers) Set the Protobin Marshallers pojoClassName:marshallerClassName[,pojoClassName:marshallerClassName,..]
void	setModule(String module) Sets the (optional) module(s) where the ClassName class is defined, that will be loaded (module,[module,..])
void	setProtobufDefinitionFile(String protobufDefFile) Set the Google Protobuf Definition File name that describes the objects to be serialized.
void	setRemoteServerList(String remoteServerList) Set the list of remote servers that make up the Infinispan cluster.
protected void	setStagingCacheName(String cacheName) An option to configure the staging cache name to use when using JDG to materialize data.

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

Field Detail

UTIL

public static final org.teiid.core.BundleUtil UTIL

Constructor Detail

InfinispanManagedConnectionFactory

public InfinispanManagedConnectionFactory()

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

getCacheSchemaConfigurator

public InfinispanSchemaDefinition getCacheSchemaConfigurator()

getCacheName

public String getCacheName()

getCacheStagingName

public String getCacheStagingName()

getCache

public org.infinispan.client.hotrod.RemoteCache getCache(String cacheName)

getCacheTypeMap

public String getCacheTypeMap()

Get the cacheName:className[;pkFieldName[:cacheJavaType]] cache type mappings.

Returns:

cacheName:className[;pkFieldName[:cacheJavaType]] cache type mappings

See Also:

setCacheTypeMap(String)

setCacheTypeMap

public void setCacheTypeMap(String cacheTypeMap)

Set the cache type mapping cacheName:className[;pkFieldName[:cacheJavaType]] that represent the root node class type for an available cache for access. The following is how the string parsed:

cacheNam = is the name used to retrieve the named cache className = is the class that is stored in the cache, and will used to create new instances [optional] pkFieldName = defined which attribute is defined as the key to the cache, this will be the key used to access the cache for updates. If not defined, updates will be disabled. Also, pkFieldName is required if the root object contains child objects that will accessible. [optional] cacheJavaType = is defined when the pkFieldName java type defined in class is different than how its stored as the key of the cache. This will enable the correct java type to be used when updates are performed and the object can be directly accessed.

Parameters:

cacheTypeMap - the cache type mappings passed in the form of cacheName:className[;pkFieldName[:cacheJavaType]]

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:

String

See Also:

setModule(java.lang.String)

getProtobufDefinitionFile

public String getProtobufDefinitionFile()

Get the Protobuf Definition File Name

Returns:

Name of the Protobuf Definition File

See Also:

setProtobufDefinitionFile(String)

setProtobufDefinitionFile

public void setProtobufDefinitionFile(String protobufDefFile)

Set the Google Protobuf Definition File name that describes the objects to be serialized.

Parameters:

protobufDefFile - the file name of the protobuf definition file to use

See Also:

getProtobufDefinitionFile()

getMessageMarshallers

public String getMessageMarshallers()

Get the Message Marshaller class names

Returns:

String comma delimited, class names of Message Marshallers

See Also:

setMessageMarshallers(String)

setMessageMarshallers

public void setMessageMarshallers(String messageMarshallers)

Set the Protobin Marshallers pojoClassName:marshallerClassName[,pojoClassName:marshallerClassName,..]

Parameters:

messageMarshallers - the class names of the marshallers to use

See Also:

getMessageMarshallers()

getMessageDescriptor

public String getMessageDescriptor()

Get the Message descriptor class name for the root object in cache

Returns:

Message Descriptor name

See Also:

setMessageDescriptor(String)

setMessageDescriptor

public void setMessageDescriptor(String messageDescriptor)

Set the name of the Message Descriptor

Parameters:

messageDescriptor - the name of the message descriptor

See Also:

getMessageDescriptor()

getStagingCacheName

public String getStagingCacheName()

setStagingCacheName

protected void setStagingCacheName(String cacheName)

An option to configure the staging cache name to use when using JDG to materialize data.

Parameters:

cacheName -

getAliasCacheName

protected String getAliasCacheName()

setAliasCacheName

protected void setAliasCacheName(String cacheName)

An option to configure the alias cache name to use when using JDG to materialize data.

Parameters:

cacheName -

getPk

public String getPk()

getCacheKeyClassType

public Class<?> getCacheKeyClassType()

This is an optional argument when defining the CacheTypeMap on the resouce adapter.

Returns:

Class

getCacheClassType

public Class<?> getCacheClassType()

Return the Class that identifies the cache object

Returns:

Class

setCacheClassTypeClass

public void setCacheClassTypeClass(Class<?> classCacheType)

getClassRegistry

public ClassRegistry getClassRegistry()

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 remote cache manager instance. If the value is missing, localhost:11311 is assumed.

Parameters:

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

getHotRodClientPropertiesFile

public String getHotRodClientPropertiesFile()

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

Returns:

the name of the HotRod client properties file to be used to configure remote cache manager

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 cache manager

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)

setCacheName

protected void setCacheName(String cacheName)
                     throws javax.resource.ResourceException

Call to set the name of the cache to access when calling getCache

Parameters:

cacheName -

Throws:

javax.resource.ResourceException

getCacheNameProxy

public CacheNameProxy getCacheNameProxy()

configuredUsingAnnotations

public boolean configuredUsingAnnotations()

isAlive

public boolean isAlive()

getCacheContainer

public org.infinispan.client.hotrod.RemoteCacheManager getCacheContainer()

setCacheContainer

protected void setCacheContainer(org.infinispan.client.hotrod.RemoteCacheManager rcm)

getContext

public org.infinispan.protostream.SerializationContext getContext()

getClassLoader

public ClassLoader getClassLoader()

loadClass

public Class<?> loadClass(String className)
                   throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

loadClasses

protected ClassLoader loadClasses()
                           throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

createCacheContainer

protected void createCacheContainer()
                             throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

createRemoteCacheFromProperties

protected org.infinispan.client.hotrod.RemoteCacheManager createRemoteCacheFromProperties(ClassLoader classLoader)
                                                                                   throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

createRemoteCacheFromServerList

protected org.infinispan.client.hotrod.RemoteCacheManager createRemoteCacheFromServerList(ClassLoader classLoader)
                                                                                   throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

registerWithCacheManager

protected void registerWithCacheManager()
                                 throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

getVersion

public Version getVersion()
                   throws TranslatorException

Throws:

TranslatorException

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()