public class ArchiveManager extends DAVAppBase
Zentrale Archiv-Verwaltung.
DAVAppBase.DisconnectHandler
Modifier and Type | Field and Description |
---|---|
static long |
DATAINDEX_OFFSET |
static boolean |
ONLY_DATA
Nur für Testzwecke; falls wahr, werden nur Datensätze mit Daten archiviert.
|
static java.lang.String |
P_CHECK_PERS_DIR_ALL |
static java.lang.String |
P_CHECK_PERS_DIR_DIR |
static java.lang.String |
P_CHECK_PERS_DIR_HDR |
static java.lang.String |
P_REMOTE_CONTROL_DEFAULT |
static java.lang.String |
P_REMOTE_CONTROL_NORC |
applicationLabel, applicationName, argList, logger
Constructor and Description |
---|
ArchiveManager(java.lang.String[] args) |
Modifier and Type | Method and Description |
---|---|
void |
archiveIsReady()
Wird von ArchiveConfig ausgeführt, wenn alle Daten initial angemeldet wurden.
|
static long |
archiveTime() |
void |
connectToDavQuit() |
int |
decreaseArchiveQueryCountForApplication(SystemObject application) |
ArchivConfig |
getArchivConfig() |
int |
getArchiveQueryCountForApplication(SystemObject application) |
DataIdentTree |
getDataIdentTree() |
InQueuesMgr |
getInQueuesMgr() |
int |
getMaximumQueriesPerApplication() |
int |
getNumCheckPersistenceThreads() |
int |
getNumCloseIndexThreads() |
int |
getNumOfArchQueuesOnline() |
int |
getNumOfArchQueuesReq() |
java.util.List<java.lang.String> |
getOriginalCommandLineArguments() |
PersistenceManager |
getPersMgr() |
SimulationManager |
getSimulationMgr() |
TaskScheduler |
getTaskScheduler() |
int |
increaseArchiveQueryCountForApplication(SystemObject application) |
static void |
main(java.lang.String[] args)
Startpunkt des Archivsystems.
|
void |
quit()
Faehrt das ArS herunter und beendet die VM.
|
void |
quitError(java.lang.String msg)
Faehrt das ArS mit einer Fehlermeldung herunter und beendet die VM.
|
void |
quitErrorNoExit(java.lang.String msg)
Faehrt das ArS mit einer Fehlermeldung herunter.
|
void |
quitNoExit()
Faehrt das ArS herunter ohne die VM zu beenden (dies ist bei Fernsteuerung des ArS aus JUnit-Tests notwendig).
|
void |
run() |
static void |
setSystemTimeOffset(long offsetSeconds)
Verstellt die Systemzeit um offset Sekunden.
|
boolean |
wasTerminated() |
close, connectToDav, disconnectFromDav, enableExplicitApplicationReadyMessage, getAsp, getAsp, getAtg, getAtg, getConfigAuth, getDataModel, getDavCon, getDD, getObj, getObj, isExplicitApplicationReadyMessage, reconnectHandler, setDisconnectHandler
public static long DATAINDEX_OFFSET
public static boolean ONLY_DATA
Nur für Testzwecke; falls wahr, werden nur Datensätze mit Daten archiviert. Es gibt dann keine Datensätze folgender Art: “keine Quelle”, “keine Daten”, “pot. Datenluecke”. Manche Testverfahren werden einfacher, wenn ausschliesslich Datensätze archiviert werden, die auch gesendet wurden.
public static final java.lang.String P_CHECK_PERS_DIR_DIR
public static final java.lang.String P_CHECK_PERS_DIR_HDR
public static final java.lang.String P_CHECK_PERS_DIR_ALL
public static final java.lang.String P_REMOTE_CONTROL_NORC
public static final java.lang.String P_REMOTE_CONTROL_DEFAULT
public ArchiveManager(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public boolean wasTerminated()
public static long archiveTime()
public static void setSystemTimeOffset(long offsetSeconds)
Verstellt die Systemzeit um offset Sekunden. NUR FÜR TESTZWECKE!!!
offsetSeconds
- Spanne in Sekundenpublic void run() throws java.lang.Exception
java.lang.Exception
public void connectToDavQuit()
public void quit()
Faehrt das ArS herunter und beendet die VM.
public void quitNoExit()
Faehrt das ArS herunter ohne die VM zu beenden (dies ist bei Fernsteuerung des ArS aus JUnit-Tests notwendig).
public void quitError(java.lang.String msg)
Faehrt das ArS mit einer Fehlermeldung herunter und beendet die VM.
public void quitErrorNoExit(java.lang.String msg)
Faehrt das ArS mit einer Fehlermeldung herunter.
public static void main(java.lang.String[] args)
Startpunkt des Archivsystems.
args
- Kommandozeilenparameterpublic ArchivConfig getArchivConfig()
public DataIdentTree getDataIdentTree()
public InQueuesMgr getInQueuesMgr()
public PersistenceManager getPersMgr()
public TaskScheduler getTaskScheduler()
public SimulationManager getSimulationMgr()
public int getMaximumQueriesPerApplication()
public java.util.List<java.lang.String> getOriginalCommandLineArguments()
public int increaseArchiveQueryCountForApplication(SystemObject application)
public int decreaseArchiveQueryCountForApplication(SystemObject application)
public int getArchiveQueryCountForApplication(SystemObject application)
public int getNumCloseIndexThreads()
public int getNumCheckPersistenceThreads()
public int getNumOfArchQueuesOnline()
public int getNumOfArchQueuesReq()
public void archiveIsReady()
Wird von ArchiveConfig ausgeführt, wenn alle Daten initial angemeldet wurden.