com.amazon.carbonado.repo.dirmi

Class ClientRepository

java.lang.Object

com.amazon.carbonado.spi.AbstractRepository<RemoteTransaction>

com.amazon.carbonado.repo.dirmi.ClientRepository

All Implemented Interfaces:

com.amazon.carbonado.capability.Capability, com.amazon.carbonado.capability.RemoteProcedureCapability, com.amazon.carbonado.capability.ShutdownCapability, com.amazon.carbonado.Repository, com.amazon.carbonado.sequence.SequenceCapability

public class ClientRepository
extends com.amazon.carbonado.spi.AbstractRepository<RemoteTransaction>
implements com.amazon.carbonado.capability.RemoteProcedureCapability

Creates a client repository from a RemoteRepository, as served by RemoteRepositoryServer. If the connection is lost, the repository can be reconnected using 'reconnect' and the Storage and SequenceValueProducer references will be retained. All transactions will be invalid following a disconnect

Author:

Brian S O'Neill, Olga Kuznetsova

Method Summary

Methods

Modifier and Type	Method and Description
<R,D> com.amazon.carbonado.capability.RemoteProcedure.Call<R,D>	beginCall(com.amazon.carbonado.capability.RemoteProcedure<R,D> proc)
protected com.amazon.carbonado.sequence.SequenceValueProducer	createSequenceValueProducer(java.lang.String name)
protected <S extends com.amazon.carbonado.Storable> com.amazon.carbonado.Storage<S>	createStorage(java.lang.Class<S> type)
static ClientRepository	from(RemoteRepository remote) Returns client access to a remote repository server.
static ClientRepository	from(java.lang.String name, RemoteRepository remote) Returns client access to a remote repository server.
static ClientRepository	from(java.lang.String name, RemoteRepository remote, com.amazon.carbonado.txn.TransactionMonitor monitor) Returns client access to a remote repository server.
<C extends com.amazon.carbonado.capability.Capability> C	getCapability(java.lang.Class<C> capabilityType)
protected org.apache.commons.logging.Log	getLog()
protected com.amazon.carbonado.txn.TransactionScope<RemoteTransaction>	localTransactionScope()
void	reconnect(RemoteRepository remote) Reconnects the repository in case of a disconnect.
protected com.amazon.carbonado.txn.TransactionManager<RemoteTransaction>	transactionManager()

Methods inherited from class com.amazon.carbonado.spi.AbstractRepository

allStorage, close, enterTopTransaction, enterTransaction, enterTransaction, getName, getSequenceValueProducer, getTransactionIsolationLevel, isAutoShutdownEnabled, isClosed, lockoutShutdown, setAutoShutdownEnabled, shutdown, shutdownHook, storageFor, unlockoutShutdown

Methods inherited from class java.lang.Object

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

Method Detail

from

public static ClientRepository from(RemoteRepository remote)
                             throws com.amazon.carbonado.RepositoryException

Returns client access to a remote repository server.

Returns:

ClientRepository instance wrapping the remote repository

Throws:

com.amazon.carbonado.RepositoryException

from

public static ClientRepository from(java.lang.String name,
                    RemoteRepository remote)
                             throws com.amazon.carbonado.RepositoryException

Returns client access to a remote repository server.

Parameters:

name - name of repository; pass null to retrieve name from remote endpoint

Returns:

ClientRepository instance wrapping the remote repository

Throws:

com.amazon.carbonado.RepositoryException

from

public static ClientRepository from(java.lang.String name,
                    RemoteRepository remote,
                    com.amazon.carbonado.txn.TransactionMonitor monitor)
                             throws com.amazon.carbonado.RepositoryException

Returns client access to a remote repository server.

Parameters:

name - name of repository; pass null to retrieve name from remote endpoint

monitor - optional transaction monitor

Returns:

ClientRepository instance wrapping the remote repository

Throws:

com.amazon.carbonado.RepositoryException

reconnect

public void reconnect(RemoteRepository remote)
               throws com.amazon.carbonado.RepositoryException

Reconnects the repository in case of a disconnect. Storage and SequenceValueProducer references will be retained. All transactions that were in process will be broken invalid after the disconnect.

Throws:

com.amazon.carbonado.RepositoryException

beginCall

public <R,D> com.amazon.carbonado.capability.RemoteProcedure.Call<R,D> beginCall(com.amazon.carbonado.capability.RemoteProcedure<R,D> proc)
                                                                    throws com.amazon.carbonado.RepositoryException

Specified by:

beginCall in interface com.amazon.carbonado.capability.RemoteProcedureCapability

Throws:

com.amazon.carbonado.RepositoryException

getCapability

public <C extends com.amazon.carbonado.capability.Capability> C getCapability(java.lang.Class<C> capabilityType)

Specified by:

getCapability in interface com.amazon.carbonado.Repository

Overrides:

getCapability in class com.amazon.carbonado.spi.AbstractRepository<RemoteTransaction>

getLog

protected org.apache.commons.logging.Log getLog()

Specified by:

getLog in class com.amazon.carbonado.spi.AbstractRepository<RemoteTransaction>

createStorage

protected <S extends com.amazon.carbonado.Storable> com.amazon.carbonado.Storage<S> createStorage(java.lang.Class<S> type)
                                                                                       throws com.amazon.carbonado.RepositoryException

Specified by:

createStorage in class com.amazon.carbonado.spi.AbstractRepository<RemoteTransaction>

Throws:

com.amazon.carbonado.RepositoryException

createSequenceValueProducer

protected com.amazon.carbonado.sequence.SequenceValueProducer createSequenceValueProducer(java.lang.String name)
                                                                                   throws com.amazon.carbonado.RepositoryException

Specified by:

createSequenceValueProducer in class com.amazon.carbonado.spi.AbstractRepository<RemoteTransaction>

Throws:

com.amazon.carbonado.RepositoryException

transactionManager

protected final com.amazon.carbonado.txn.TransactionManager<RemoteTransaction> transactionManager()

Specified by:

transactionManager in class com.amazon.carbonado.spi.AbstractRepository<RemoteTransaction>

localTransactionScope

protected final com.amazon.carbonado.txn.TransactionScope<RemoteTransaction> localTransactionScope()

Specified by:

localTransactionScope in class com.amazon.carbonado.spi.AbstractRepository<RemoteTransaction>