org.teiid.resource.adapter.infinispan.dsl.base

Class AbstractInfinispanManagedConnectionFactory

java.lang.Object

org.teiid.resource.spi.BasicManagedConnectionFactory

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

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 org.infinispan.client.hotrod.RemoteCacheManager	createRemoteCacheWrapperFromProperties(ClassLoader classLoader)
protected abstract org.infinispan.client.hotrod.RemoteCacheManager	createRemoteCacheWrapperFromServerList(ClassLoader classLoader)
boolean	equals(Object obj)
protected org.infinispan.client.hotrod.RemoteCacheManager	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.
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	getPkMap(String cacheName)
String	getProtobinFile() Get the Protobin File Name
String	getRemoteServerList() Returns the host:port[;host:port...] list that identifies the remote servers to include in this cluster;
int	hashCode()
boolean	isAlive()
protected Class<?>	loadClass(String className)
protected ClassLoader	loadClasses()
protected void	registerMarshallers(org.infinispan.protostream.SerializationContext ctx, ClassLoader cl)
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.
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	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 classname[,classname,..]
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	setProtobinFile(String protobinFile) Set the Google Protobin 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.

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:

String

See Also:

setModule(java.lang.String)

getProtobinFile

public String getProtobinFile()

Get the Protobin File Name

Returns:

Name of the Protobin File

See Also:

setProtobinFile(String)

setProtobinFile

public void setProtobinFile(String protobinFile)

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

Parameters:

protobinFile - the file name of the protobin file to use

See Also:

getProtobinFile()

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 classname[,classname,..]

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

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)

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)

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

createRemoteCacheWrapperFromProperties

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

Throws:

javax.resource.ResourceException

createRemoteCacheWrapperFromServerList

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

Throws:

javax.resource.ResourceException

registerMarshallers

protected void registerMarshallers(org.infinispan.protostream.SerializationContext ctx,
                       ClassLoader cl)
                            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()