com.amazon.carbonado.repo.dirmi

Class RemoteRepositoryServer

java.lang.Object

com.amazon.carbonado.repo.dirmi.RemoteRepositoryServer

All Implemented Interfaces:

RemoteRepository, java.rmi.Remote

public class RemoteRepositoryServer
extends java.lang.Object
implements RemoteRepository

Wraps a repository for server-side access, which can be accessed on the client by ClientRepository.

Author:

Brian S O'Neill

Nested Class Summary

Nested classes/interfaces inherited from interface com.amazon.carbonado.repo.dirmi.RemoteRepository

RemoteRepository.StorageResponse

Method Summary

Methods

Modifier and Type	Method and Description
RemoteTransaction	enterTopTransaction(com.amazon.carbonado.IsolationLevel level)
RemoteTransaction	enterTopTransaction(com.amazon.carbonado.IsolationLevel level, int timeout, java.util.concurrent.TimeUnit unit)
RemoteTransaction	enterTransaction(RemoteTransaction parent, com.amazon.carbonado.IsolationLevel level)
RemoteTransaction	enterTransaction(RemoteTransaction parent, com.amazon.carbonado.IsolationLevel level, int timeout, java.util.concurrent.TimeUnit unit)
static RemoteRepository	from(com.amazon.carbonado.Repository repo) Returns a remotely servable repository.
RemoteIndexEntryAccessCapability	getIndexEntryAccessCapability()
java.lang.String	getName()
RemoteResyncCapability	getResyncCapability()
RemoteSequenceValueProducer	getSequenceValueProducer(java.lang.String name)
RemoteProcedureExecutor	newRemoteProcedureExecutor(RemoteStorageRequestor r) Client repository should call this once and re-use the returned instance.
RemoteStorageTransport	storageFor(StorableTypeTransport transport)
org.cojen.dirmi.Pipe	storageRequest(RemoteRepository.StorageResponse response, org.cojen.dirmi.Pipe pipe)

Methods inherited from class java.lang.Object

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

Method Detail

from

public static RemoteRepository from(com.amazon.carbonado.Repository repo)

Returns a remotely servable repository.

getName

public java.lang.String getName()

Specified by:

getName in interface RemoteRepository

storageFor

public RemoteStorageTransport storageFor(StorableTypeTransport transport)
                                  throws com.amazon.carbonado.RepositoryException

Specified by:

storageFor in interface RemoteRepository

Throws:

com.amazon.carbonado.RepositoryException

storageRequest

public org.cojen.dirmi.Pipe storageRequest(RemoteRepository.StorageResponse response,
                                  org.cojen.dirmi.Pipe pipe)

Specified by:

storageRequest in interface RemoteRepository

enterTransaction

public RemoteTransaction enterTransaction(RemoteTransaction parent,
                                 com.amazon.carbonado.IsolationLevel level)

Specified by:

enterTransaction in interface RemoteRepository

enterTransaction

public RemoteTransaction enterTransaction(RemoteTransaction parent,
                                 com.amazon.carbonado.IsolationLevel level,
                                 int timeout,
                                 java.util.concurrent.TimeUnit unit)

Specified by:

enterTransaction in interface RemoteRepository

enterTopTransaction

public RemoteTransaction enterTopTransaction(com.amazon.carbonado.IsolationLevel level)

Specified by:

enterTopTransaction in interface RemoteRepository

enterTopTransaction

public RemoteTransaction enterTopTransaction(com.amazon.carbonado.IsolationLevel level,
                                    int timeout,
                                    java.util.concurrent.TimeUnit unit)

Specified by:

enterTopTransaction in interface RemoteRepository

getSequenceValueProducer

public RemoteSequenceValueProducer getSequenceValueProducer(java.lang.String name)
                                                     throws com.amazon.carbonado.RepositoryException

Specified by:

getSequenceValueProducer in interface RemoteRepository

Throws:

com.amazon.carbonado.RepositoryException

newRemoteProcedureExecutor

public RemoteProcedureExecutor newRemoteProcedureExecutor(RemoteStorageRequestor r)

Description copied from interface: RemoteRepository

Client repository should call this once and re-use the returned instance.

Specified by:

newRemoteProcedureExecutor in interface RemoteRepository

getResyncCapability

public RemoteResyncCapability getResyncCapability()

Specified by:

getResyncCapability in interface RemoteRepository

getIndexEntryAccessCapability

public RemoteIndexEntryAccessCapability getIndexEntryAccessCapability()
                                                               throws java.rmi.RemoteException

Specified by:

getIndexEntryAccessCapability in interface RemoteRepository

Throws:

java.rmi.RemoteException