org.teiid.resource.adapter.infinispan.hotrod

Class InfinispanConnectionImpl

java.lang.Object

org.teiid.resource.spi.BasicConnection

org.teiid.resource.adapter.infinispan.hotrod.InfinispanConnectionImpl

All Implemented Interfaces:

javax.resource.cci.Connection, InfinispanConnection

public class InfinispanConnectionImpl
extends BasicConnection
implements InfinispanConnection

Constructor Summary

Constructors

Constructor and Description
InfinispanConnectionImpl(org.infinispan.client.hotrod.RemoteCacheManager manager, org.infinispan.client.hotrod.RemoteCacheManager scriptManager, String cacheName, org.infinispan.protostream.SerializationContext ctx, org.teiid.resource.adapter.infinispan.hotrod.InfinispanManagedConnectionFactory.InfinispanConnectionFactory icf)

Method Summary

Modifier and Type	Method and Description
void	close()
<T> T	execute(String scriptName, Map<String,?> params)
org.infinispan.commons.api.BasicCache	getCache()
org.infinispan.commons.api.BasicCacheContainer	getCacheFactory()
void	registerMarshaller(org.infinispan.protostream.BaseMarshaller<InfinispanDocument> marshaller)
void	registerProtobufFile(ProtobufResource protobuf)
void	registerScript(String scriptName, String script)
void	unRegisterMarshaller(org.infinispan.protostream.BaseMarshaller<InfinispanDocument> marshaller)

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

cleanUp, createInteraction, getLocalTransaction, getMetaData, getResultSetInfo, getXAResource, isAlive

Methods inherited from class java.lang.Object

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

Constructor Detail

InfinispanConnectionImpl

public InfinispanConnectionImpl(org.infinispan.client.hotrod.RemoteCacheManager manager,
                                org.infinispan.client.hotrod.RemoteCacheManager scriptManager,
                                String cacheName,
                                org.infinispan.protostream.SerializationContext ctx,
                                org.teiid.resource.adapter.infinispan.hotrod.InfinispanManagedConnectionFactory.InfinispanConnectionFactory icf)
                         throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

Method Detail

registerProtobufFile

public void registerProtobufFile(ProtobufResource protobuf)
                          throws TranslatorException

Specified by:

registerProtobufFile in interface InfinispanConnection

Throws:

TranslatorException

getCacheFactory

public org.infinispan.commons.api.BasicCacheContainer getCacheFactory()
                                                               throws TranslatorException

Specified by:

getCacheFactory in interface InfinispanConnection

Throws:

TranslatorException

close

public void close()
           throws javax.resource.ResourceException

Specified by:

close in interface javax.resource.cci.Connection

Throws:

javax.resource.ResourceException

getCache

public org.infinispan.commons.api.BasicCache getCache()
                                               throws TranslatorException

Specified by:

getCache in interface InfinispanConnection

Throws:

TranslatorException

registerMarshaller

public void registerMarshaller(org.infinispan.protostream.BaseMarshaller<InfinispanDocument> marshaller)
                        throws TranslatorException

Specified by:

registerMarshaller in interface InfinispanConnection

Throws:

TranslatorException

unRegisterMarshaller

public void unRegisterMarshaller(org.infinispan.protostream.BaseMarshaller<InfinispanDocument> marshaller)
                          throws TranslatorException

Specified by:

unRegisterMarshaller in interface InfinispanConnection

Throws:

TranslatorException

execute

public <T> T execute(String scriptName,
                     Map<String,?> params)

Specified by:

execute in interface InfinispanConnection

registerScript

public void registerScript(String scriptName,
                           String script)

Specified by:

registerScript in interface InfinispanConnection