org.resoa.persistence

Class PersistentDomain

java.lang.Object

org.resoa.persistence.PersistentDomain

All Implemented Interfaces:

ManagedQueue.OnRemoveCallback<Task>

public class PersistentDomain
extends java.lang.Object
implements ManagedQueue.OnRemoveCallback<Task>

Persistent services for a domain

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	KEY_TASKCOMMITTED

Constructor Summary

Constructors

Constructor and Description
PersistentDomain(org.resoa.service.DomainDescriptor domDesc, PersistenceConfig persistenceConfig, Persistor persistor) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	backup(Persistor persistor, boolean enforce) create hot backup of domain
void	checkForJournal(Task task) Create Journal file of LOGIFLEPERSIST status.
void	closePersistence() We mark as not persistent
org.resoa.util.SymCipher	getAes()
CacheManager	getCacheManager()
java.lang.ClassLoader	getClassLoader()
java.lang.String	getDatabaseDir()
DatabaseTransition	getDbTransition()
java.lang.String	getDomain()
org.resoa.service.DomainDescriptor	getDomainDescriptor()
ExecutionLogManager	getExecutionLogManager()
java.lang.String	getJournalDir()
LockManager	getLockManager()
long	getNextBackupTime()
PersistenceConfig	getPersistConfig()
org.resoa.topology.PersistentDomainConfig	getPersistDomainConfig()
PersistenceMode	getPersistenceMode() Returns the Persistence mode
Persistor	getPersistor()
TransactionLogger	getTransactionLogger()
boolean	isMaster()
boolean	isSlave()
boolean	isSynchronizing()
void	onRemove(Task task)
void	queueTask(Task task) Queue a task for SLAVE execution
void	setDbTransition(DatabaseTransition dbTransition)
void	setMode(PersistenceMode mode) Change the Persistence Runtime mode If set to SLAVE, the execution log will be requested from domain MASTER node, if set to MASTER, outstanding task journals will be processed into storage.
void	setTransactionLogger(TransactionLogger transactionLogger)
void	signalSyncComplete() Signal synchronization complete
int	waitForSync() Wait for Slave synchronization

Methods inherited from class java.lang.Object

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

Field Detail

KEY_TASKCOMMITTED

public static java.lang.String KEY_TASKCOMMITTED

Constructor Detail

PersistentDomain

public PersistentDomain(org.resoa.service.DomainDescriptor domDesc,
                PersistenceConfig persistenceConfig,
                Persistor persistor)
                 throws org.resoa.exception.PersistenceException

Constructor

Parameters:

domDesc -

persistenceConfig -

persistor -

Throws:

org.resoa.exception.PersistenceException

Method Detail

getAes

public org.resoa.util.SymCipher getAes()

Returns:

the AES Cipher

getClassLoader

public java.lang.ClassLoader getClassLoader()

Returns:

the classLoader

setTransactionLogger

public void setTransactionLogger(TransactionLogger transactionLogger)

Parameters:

transactionLogger - the transactionLogger to set

getTransactionLogger

public TransactionLogger getTransactionLogger()

Returns:

the transactionLogger

getPersistor

public Persistor getPersistor()

Returns:

the persistor

getDomainDescriptor

public org.resoa.service.DomainDescriptor getDomainDescriptor()

getPersistDomainConfig

public org.resoa.topology.PersistentDomainConfig getPersistDomainConfig()

Returns:

the persistDomainConfig

getDbTransition

public DatabaseTransition getDbTransition()

Returns:

the dbTransition

setDbTransition

public void setDbTransition(DatabaseTransition dbTransition)
                     throws org.resoa.exception.PersistenceException

Parameters:

dbTransition - the dbTransition to set

Throws:

org.resoa.exception.PersistenceException

getLockManager

public LockManager getLockManager()

Returns:

the lockManager

getCacheManager

public CacheManager getCacheManager()

Returns:

the cacheManager

getDatabaseDir

public java.lang.String getDatabaseDir()

Returns:

the databaseDir

getJournalDir

public java.lang.String getJournalDir()

Returns:

the journalDir

getExecutionLogManager

public ExecutionLogManager getExecutionLogManager()

getPersistConfig

public PersistenceConfig getPersistConfig()

getPersistenceMode

public PersistenceMode getPersistenceMode()

Returns the Persistence mode

Returns:

the Persistence mode of the domain

isMaster

public boolean isMaster()

Returns:

True, if the Service Domain is running in MASTER mode

isSlave

public boolean isSlave()

Returns:

True, if the Service Domain is running in SLAVE mode

isSynchronizing

public boolean isSynchronizing()

Returns:

true, if the Service Domain is synchronizing the Execution Log

waitForSync

public int waitForSync()

Wait for Slave synchronization

signalSyncComplete

public void signalSyncComplete()

Signal synchronization complete

getNextBackupTime

public long getNextBackupTime()

Returns:

the nextBackupTime

backup

public void backup(Persistor persistor,
          boolean enforce)
            throws StorageException

create hot backup of domain

Parameters:

persistor -

enforce - if false, the backup will only run if BackupInfo information indicates backup requirement

Throws:

StorageException

closePersistence

public void closePersistence()

We mark as not persistent

queueTask

public void queueTask(Task task)
               throws org.resoa.exception.PersistenceException

Queue a task for SLAVE execution

Parameters:

task -

Throws:

org.resoa.exception.PersistenceException

checkForJournal

public void checkForJournal(Task task)

Create Journal file of LOGIFLEPERSIST status. It checks before, if a taskID already got a MASTERCOMMIT. Relevant, if a LOGFILEPERSIST status arrives after a MASTERCOMMIT due to network latency.

Parameters:

task - the task

setMode

public void setMode(PersistenceMode mode)

Change the Persistence Runtime mode If set to SLAVE, the execution log will be requested from domain MASTER node, if set to MASTER, outstanding task journals will be processed into storage.

Parameters:

mode - the mode to set

getDomain

public java.lang.String getDomain()

Returns:

the domain

onRemove

public void onRemove(Task task)

Specified by:

onRemove in interface ManagedQueue.OnRemoveCallback<Task>