org.teiid.resource.adapter.infinispan.hotrod

Class AbstractInfinispanManagedConnectionFactory

java.lang.Object

org.teiid.resource.spi.BasicManagedConnectionFactory

org.teiid.resource.adapter.infinispan.hotrod.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

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,org.infinispan.protostream.BaseMarshaller>	messageMarshallerMap

Constructor Summary

Constructors

Constructor and Description
AbstractInfinispanManagedConnectionFactory()

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
protected void	createCacheContainer()
BasicConnectionFactory<InfinispanConnectionImpl>	createConnectionFactory()
protected abstract org.infinispan.client.hotrod.RemoteCacheManager	createRemoteCacheFromProperties(ClassLoader classLoader)
protected abstract org.infinispan.client.hotrod.RemoteCacheManager	createRemoteCacheFromServerList(ClassLoader classLoader)
boolean	equals(Object obj)
String	getAliasCacheName()
org.infinispan.client.hotrod.RemoteCache	getCache()
org.infinispan.client.hotrod.RemoteCache	getCache(String cacheName)
Class<?>	getCacheClassType() Return the Class that identifies the cache object
protected 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()
String	getCacheNameForUpdate()
CacheNameProxy	getCacheNameProxy()
String	getCacheTypeMap() Get the cacheName:className[;pkFieldName[:cacheJavaType]] cache type mappings.
protected ClassLoader	getClassLoader()
ClassRegistry	getClassRegistry()
protected abstract 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()
int	hashCode()
boolean	isAlive()
protected Class<?>	loadClass(String className)
protected ClassLoader	loadClasses()
protected void	registerWithCacheManager(org.infinispan.protostream.SerializationContext ctx, org.infinispan.client.hotrod.RemoteCacheManager cc, ClassLoader cl, boolean useAnnotations)
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.
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

messageMarshallerMap

protected Map<String,org.infinispan.protostream.BaseMarshaller> messageMarshallerMap

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

getCacheName

public String getCacheName()

getCacheNameForUpdate

public String getCacheNameForUpdate()

getCache

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

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

public void setStagingCacheName(String cacheName)

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

Parameters:

cacheName -

getAliasCacheName

public String getAliasCacheName()

setAliasCacheName

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

isAlive

public boolean isAlive()

getCacheContainer

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

setCacheContainer

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

getContext

protected abstract org.infinispan.protostream.SerializationContext getContext()

getClassLoader

protected ClassLoader getClassLoader()

loadClass

protected 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 abstract org.infinispan.client.hotrod.RemoteCacheManager createRemoteCacheFromProperties(ClassLoader classLoader)
                                                                                            throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

createRemoteCacheFromServerList

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

Throws:

javax.resource.ResourceException

registerWithCacheManager

protected void registerWithCacheManager(org.infinispan.protostream.SerializationContext ctx,
                                        org.infinispan.client.hotrod.RemoteCacheManager cc,
                                        ClassLoader cl,
                                        boolean useAnnotations)
                                 throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

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