Package de.bsvrz.ars.ars.mgmt
Class InQueuesMgr
java.lang.Object
de.bsvrz.ars.ars.mgmt.InQueuesMgr
public final class InQueuesMgr
extends java.lang.Object
Warteschlangen-Manager. Verteilt reinkommende Datentelegramm mit Datensätzen/Archivanfragen/Archiv-Informationsanfragen/
Backup-/Restore-/HeaderRestore-/LZV/Delete-/RequestGap-Aufträgen auf die jeweilige Warteschlange.
-
Nested Class Summary
Nested Classes Modifier and Type Class Description classInQueuesMgr.ArchiveDataReceiverEmpfaengerklasse für ArchivdatenclassInQueuesMgr.ArchiveSettingsReceiverEmpfaengerklasse für ArchiveinstellungenclassInQueuesMgr.DataAckSenderclassInQueuesMgr.DataReceiverAbstrakte Klasse, die zum Empfang bestimmter Daten (z.B. von Archiv-Queries) verwendet werden kann.classInQueuesMgr.QueryReceiverEmpfaengerklasse für Archivanfragen -
Field Summary
Fields Modifier and Type Field Description static intNUM_OF_NONARCH_QUEUESstatic intNUM_OF_SINGLETASKSstatic intQ_ARC_SETT_IDXstatic intQ_ARCINF_IDXstatic intQ_BACKUP_IDXstatic intQ_DELETE_IDXstatic intQ_HDR_REST_IDXstatic intQ_LZV_IDXstatic intQ_NUM_QRY_INF_IDXstatic intQ_QRYA_IDXIndexe der Eingangswarteschlangenstatic intQ_QRYB_IDXstatic intQ_QRYC_IDXstatic intQ_REQ_GAP_IDXstatic intQ_RESTORE_IDXstatic intQ_SIMPARAM_IDXstatic intST_ARC_SETT_IDXstatic intST_BACKUP_IDXstatic intST_DELETE_IDXstatic intST_HDR_REST_IDXstatic intST_LZV_IDXstatic intST_MIRROR_IDXstatic intST_NUM_QRY_INF_IDXstatic intST_REQ_GAP_IDXstatic intST_RESTORE_IDX -
Constructor Summary
Constructors Constructor Description InQueuesMgr(ArchiveManager aMgr, DataIdentTree dTree, QueueParameters parameters)Erzeugt den Warteschlangen-Manager. -
Method Summary
Modifier and Type Method Description intcalcOnlineArchivTaskIndex(long objID, long atgID, long aspID, int simVar)Verteilung der Datenidentifikationen auf die Online-Archiv-Tasks erfolgt anhand der IDs.intcountOnlineDataInQueues()voiddecrOnlineDataInQueues()InQueuesMgr.ArchiveDataReceivergetArchiveDataReceiver()Die KlasseArchivConfigmeldet die zu archivierenden Daten mit dem Objekt als Empfaenger an, das von dieser Methode geliefert wird.float[][]getArchiveQueuesOnlineStatus()float[][]getArchiveQueuesRequestedStatus()ArchiveSettingsTaskgetArchiveSettingsTask()Liefert den Task, der für die Bearbeitung der Archiveinstellungen verantwortlich ist.longgetCloseContainerSuccess()InQueuesMgr.DataAckSendergetDataAckSender()Die KlasseArchivConfigmeldet die Quittungen für die zu archivierenden Daten mit dem Objekt als Sender an, das von dieser Methode geliefert wird.longgetFailedCountOnline()longgetFailedCountRequested()longgetFailedCountTotal()intgetHiQueryTaskNum()intgetInitialCapacityOfOnlineQueues()Initiale Maximalgröße eines Ringpuffers für aktuelle Datensätze.intgetInitialCapacityOfRequestedQueue()Kapazität des Ringpuffers für nachgelieferte DatensätzeintgetLoQueryTaskNum()intgetMidQueryTaskNum()float[][]getNonArchiveQueuesStatus()intgetNumOfArchQueuesOnline()Zahl der Tasks, die aktuelle Datensätze archivieren (sollte Primzahl sein)voidgetObjectsFromDav()In dieser Methode wird allen Tasks (falls notwendig) die Möglichkeit gegeben, benoetigte Objekte vom DAV zu laden.ArchiveTaskgetOnlineArchiveTask(long objId, long atgId, long aspId, int simVar)Nur für Testzwecke: Liefert den gewuenschten ArchiveTaskintgetOnlineQueueResizeBlockSize()Größe der Blocks, in denen die Online-Queues vergrößert oder verkleinert werdenlonggetProcessedCountOnline()longgetProcessedCountRequested()longgetProcessedCountTotal()longgetQueuedCountOnline()longgetQueuedCountTotal()doublegetQueueLoad()longgetQueuesCountRequested()longgetReceivedCountOnline()AbstractTaskgetSingleTask(int taskIndex)Liefert den gewuenschten SingleTask (um etwa Listener einzuhängen)longgetSuccessCountOnline()longgetSuccessCountRequested()longgetSuccessCountTotal()intgetTotalCapacityOfOnlineQueues()Gesamtgröße (Summe) der Online-QueuesintgetTotalCapacityOfRequestedQueues()Gesamtgröße (Summe) der Nachgefordert-QueuesintgetTotalOnlineQueuesCapa()voidinsertCloseContainer(long objID, ArchiveTask.CloseContainerObject cco)voidinsertInArchiveQueueReq(long archiveTime, java.lang.Object ad)Fuegt einen nachgeforderten Datensatz in die entsprechende Queue ein.booleaninsertInBackupQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem Sicherungs-Task einen Auftrag hinzu.booleaninsertInDeleteRegularQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem Lösch-Task (automatisches Löschen) einen Auftrag hinzu.booleaninsertInLZVQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem LZV-Task einen Auftrag hinzu.booleaninsertInRequestQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem Nachfordern-Task einen Auftrag hinzu.booleaninsertInSimVarDeleteQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem Simulationsvarianten-Lösch-Task einen Auftrag hinzu.booleaninsertSimVarParam(SimulationResultData resultData)Fügt dem Parametrierungs-Task einen weiteren Auftrag hinzu.protected voidlogCapaNoLongerExceeded(int maxsize, java.lang.String qname, int leftouts)protected voidlogSendMsgCapaExceeded(int maxsize, java.lang.String qname, de.bsvrz.dav.daf.main.ResultData rd)Betriebsmeldung absetzen: Warteschlange voll.voidresetDSCounter()Setzt alle Zähler auf 0.voidsetFastExit(boolean quickExit)Setzt, ob sich der InQueuesMgr schnell terminieren soll.voidsetFreeDiskSpace(long freeDiskSpace)Aktualisiert den freien SpeicherplatzvoidsetQueryTaskNumbers(int numHi, int numMid, int numLo)Setzt die Anzahl der Threads für Archivanfragen auf die angegebenen Werte.voidstartAllTasks()Startet alle Tasks (Multi- und Single-Tasks) sowie die Archiv-Tasks.voidstopAllTasks()Beendet alle Tasks (Multi- und Single-Tasks) sowie die Archiv-Tasks.booleansubscribe(de.bsvrz.dav.daf.main.ClientDavInterface davCon, de.bsvrz.dav.daf.main.config.SystemObject so, de.bsvrz.dav.daf.main.DataDescription dataDescription)Anmelden mit Verzögerung (Sliding-Window-Mechanismus)voidsubscribeQueries()In dieser Methode wird allen Tasks (falls notwendig) die Möglichkeit gegeben, sich auf Objekte anzumelden.voidsubscribeSettings()In dieser Methode wird allen Tasks (falls notwendig) die Möglichkeit gegeben, sich auf Objekte anzumelden.voidsuspendNonWriteTasksDirect()Hält alle lesenen Tasks direkt an, ohne weitere Bedingungen zu prüfen.voidsuspendTaskIfNecessary(AbstractTask task)Prüft ob Tasks temporaer blockiert werden sollen und blockiert ggf. den aufrufenden Task.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Field Details
-
ST_ARC_SETT_IDX
public static final int ST_ARC_SETT_IDX- See Also:
- Constant Field Values
-
ST_BACKUP_IDX
public static final int ST_BACKUP_IDX- See Also:
- Constant Field Values
-
ST_RESTORE_IDX
public static final int ST_RESTORE_IDX- See Also:
- Constant Field Values
-
ST_HDR_REST_IDX
public static final int ST_HDR_REST_IDX- See Also:
- Constant Field Values
-
ST_LZV_IDX
public static final int ST_LZV_IDX- See Also:
- Constant Field Values
-
ST_DELETE_IDX
public static final int ST_DELETE_IDX- See Also:
- Constant Field Values
-
ST_REQ_GAP_IDX
public static final int ST_REQ_GAP_IDX- See Also:
- Constant Field Values
-
ST_NUM_QRY_INF_IDX
public static final int ST_NUM_QRY_INF_IDX- See Also:
- Constant Field Values
-
ST_MIRROR_IDX
public static final int ST_MIRROR_IDX- See Also:
- Constant Field Values
-
NUM_OF_SINGLETASKS
public static final int NUM_OF_SINGLETASKS- See Also:
- Constant Field Values
-
Q_QRYA_IDX
public static final int Q_QRYA_IDXIndexe der Eingangswarteschlangen- See Also:
- Constant Field Values
-
Q_QRYB_IDX
public static final int Q_QRYB_IDX- See Also:
- Constant Field Values
-
Q_QRYC_IDX
public static final int Q_QRYC_IDX- See Also:
- Constant Field Values
-
Q_ARCINF_IDX
public static final int Q_ARCINF_IDX- See Also:
- Constant Field Values
-
Q_BACKUP_IDX
public static final int Q_BACKUP_IDX- See Also:
- Constant Field Values
-
Q_RESTORE_IDX
public static final int Q_RESTORE_IDX- See Also:
- Constant Field Values
-
Q_HDR_REST_IDX
public static final int Q_HDR_REST_IDX- See Also:
- Constant Field Values
-
Q_LZV_IDX
public static final int Q_LZV_IDX- See Also:
- Constant Field Values
-
Q_DELETE_IDX
public static final int Q_DELETE_IDX- See Also:
- Constant Field Values
-
Q_REQ_GAP_IDX
public static final int Q_REQ_GAP_IDX- See Also:
- Constant Field Values
-
Q_ARC_SETT_IDX
public static final int Q_ARC_SETT_IDX- See Also:
- Constant Field Values
-
Q_SIMPARAM_IDX
public static final int Q_SIMPARAM_IDX- See Also:
- Constant Field Values
-
Q_NUM_QRY_INF_IDX
public static final int Q_NUM_QRY_INF_IDX- See Also:
- Constant Field Values
-
NUM_OF_NONARCH_QUEUES
public static final int NUM_OF_NONARCH_QUEUES- See Also:
- Constant Field Values
-
-
Constructor Details
-
InQueuesMgr
Erzeugt den Warteschlangen-Manager.- Parameters:
aMgr- Archiv-ManagerdTree- DataIdentTreeparameters- Queue-Einstellungen
-
-
Method Details
-
subscribe
public boolean subscribe(de.bsvrz.dav.daf.main.ClientDavInterface davCon, de.bsvrz.dav.daf.main.config.SystemObject so, de.bsvrz.dav.daf.main.DataDescription dataDescription) throws java.lang.InterruptedExceptionAnmelden mit Verzögerung (Sliding-Window-Mechanismus)- Parameters:
davCon- Datenverteilerverbindungso- ObjektdataDescription- DataDescription- Returns:
- true wenn die Anmeldung durchgeführt werden konnte, sonst false (z.B. bei Anmeldung eines Empfängers auf Senke-Aspekt)
- Throws:
java.lang.InterruptedException
-
getNumOfArchQueuesOnline
public final int getNumOfArchQueuesOnline()Zahl der Tasks, die aktuelle Datensätze archivieren (sollte Primzahl sein) -
setQueryTaskNumbers
public void setQueryTaskNumbers(int numHi, int numMid, int numLo)Setzt die Anzahl der Threads für Archivanfragen auf die angegebenen Werte. Falls Threads entfernt werden, werden noch behandelte Anfragen zuende bearbeitet.- Parameters:
numHi- Anzahl Tasks der Prioritaet "hoch"numMid- Anzahl Tasks der Prioritaet "mittel"numLo- Anzahl Tasks der Prioritaet "niedrig"
-
getHiQueryTaskNum
public int getHiQueryTaskNum() -
getMidQueryTaskNum
public int getMidQueryTaskNum() -
getLoQueryTaskNum
public int getLoQueryTaskNum() -
suspendTaskIfNecessary
Prüft ob Tasks temporaer blockiert werden sollen und blockiert ggf. den aufrufenden Task.Diese Methode und
suspendNonWriteTasks()verwenden eine reduzierte Synchronisierung um die Zahl der durchlaufenen synchronized-Bloecke gering zu halten.Diese Methode darf nur ausgeführt werden, wenn der task nicht auf eine Datenidentifikation synchronisiert ist (Deadlock-Gefahr)
- Parameters:
task-- Throws:
java.lang.InterruptedException- Thread unterbrochen
-
suspendNonWriteTasksDirect
public void suspendNonWriteTasksDirect()Hält alle lesenen Tasks direkt an, ohne weitere Bedingungen zu prüfen. -
getObjectsFromDav
public void getObjectsFromDav()In dieser Methode wird allen Tasks (falls notwendig) die Möglichkeit gegeben, benoetigte Objekte vom DAV zu laden. -
subscribeSettings
public void subscribeSettings()In dieser Methode wird allen Tasks (falls notwendig) die Möglichkeit gegeben, sich auf Objekte anzumelden. Abmelden geschieht zentral über denConnectionManager. -
subscribeQueries
public void subscribeQueries()In dieser Methode wird allen Tasks (falls notwendig) die Möglichkeit gegeben, sich auf Objekte anzumelden. Abmelden geschieht zentral über denConnectionManager. -
startAllTasks
public void startAllTasks()Startet alle Tasks (Multi- und Single-Tasks) sowie die Archiv-Tasks. -
stopAllTasks
public void stopAllTasks() throws java.lang.InterruptedExceptionBeendet alle Tasks (Multi- und Single-Tasks) sowie die Archiv-Tasks.- Throws:
java.lang.InterruptedException- Thread unterbrochen
-
calcOnlineArchivTaskIndex
public int calcOnlineArchivTaskIndex(long objID, long atgID, long aspID, int simVar)Verteilung der Datenidentifikationen auf die Online-Archiv-Tasks erfolgt anhand der IDs. Jede Datenidentifikation wird somit immer in dieselbe ArchiveQueue eingefuegt. Auf diese Weise kann die Reihenfolge des Eintreffens wesentlich einfacher erhalten werden.- Parameters:
objID- Objekt-IDatgID- Attributgruppen-IDaspID- Aspekt-IDsimVar- Simulationsvariante- Returns:
- Summe der IDs und simVar modulo Anzahl der ArchivTasks
-
insertInArchiveQueueReq
public void insertInArchiveQueueReq(long archiveTime, java.lang.Object ad)Fuegt einen nachgeforderten Datensatz in die entsprechende Queue ein.- Parameters:
archiveTime- Archivzeitad- Datensatz
-
insertInSimVarDeleteQueue
public boolean insertInSimVarDeleteQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem Simulationsvarianten-Lösch-Task einen Auftrag hinzu.- Parameters:
resultData- Auftrag.- Returns:
truefalls der Auftrag eingefügt werden konnte.falsesonst.
-
insertSimVarParam
Fügt dem Parametrierungs-Task einen weiteren Auftrag hinzu.- Parameters:
resultData- Auftrag. Enthält Informationen, auf welche Datenidentifikationen sich das Archivsystem anmelden soll.- Returns:
truefalls der Auftrag eingefügt werden konnte.falsesonst.
-
insertInDeleteRegularQueue
public boolean insertInDeleteRegularQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem Lösch-Task (automatisches Löschen) einen Auftrag hinzu.- Parameters:
resultData- Auftrag.- Returns:
truefalls der Auftrag eingefügt werden konnte.falsesonst.
-
insertInRequestQueue
public boolean insertInRequestQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem Nachfordern-Task einen Auftrag hinzu.- Parameters:
resultData- Auftrag.- Returns:
truefalls der Auftrag eingefügt werden konnte.falsesonst.
-
insertInLZVQueue
public boolean insertInLZVQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem LZV-Task einen Auftrag hinzu.- Parameters:
resultData- Auftrag.- Returns:
truefalls der Auftrag eingefügt werden konnte.falsesonst.
-
insertInBackupQueue
public boolean insertInBackupQueue(de.bsvrz.dav.daf.main.ResultData resultData)Fügt dem Sicherungs-Task einen Auftrag hinzu.- Parameters:
resultData- Auftrag.- Returns:
truefalls der Auftrag eingefügt werden konnte.falsesonst.
-
insertCloseContainer
-
logSendMsgCapaExceeded
protected void logSendMsgCapaExceeded(int maxsize, java.lang.String qname, de.bsvrz.dav.daf.main.ResultData rd)Betriebsmeldung absetzen: Warteschlange voll.- Parameters:
maxsize- Kapazität der Warteschlangeqname- Name der Warteschlangerd- Datensatz.
-
logCapaNoLongerExceeded
protected void logCapaNoLongerExceeded(int maxsize, java.lang.String qname, int leftouts) -
getArchiveQueuesOnlineStatus
public float[][] getArchiveQueuesOnlineStatus()- Returns:
- Status der Warteschlangen für aktuelle Datensätze
-
getArchiveQueuesRequestedStatus
public float[][] getArchiveQueuesRequestedStatus()- Returns:
- Status der Warteschlangen für nachgelieferte Datensätze
-
getNonArchiveQueuesStatus
public float[][] getNonArchiveQueuesStatus()- Returns:
- Status der Warteschlangen für eingehende, nicht zu archivierende Objekte
-
getTotalOnlineQueuesCapa
public int getTotalOnlineQueuesCapa()- Returns:
- Gesamtkapazitaet aller Ringpuffers für aktuelle Datensätze
-
getQueueLoad
public double getQueueLoad()- Returns:
- Auslastungsgrad der Warteschlangen. Anhand dieses Wertes wird ermittelt, ob die Bearbeitung nicht schreibender Tasks ausgesetzt wird.
-
countOnlineDataInQueues
public int countOnlineDataInQueues() -
resetDSCounter
public void resetDSCounter()Setzt alle Zähler auf 0. -
decrOnlineDataInQueues
public void decrOnlineDataInQueues() -
getOnlineArchiveTask
Nur für Testzwecke: Liefert den gewuenschten ArchiveTask- Parameters:
objId- Objekt-IDatgId- Attributgruppen-IDaspId- Aspekt-IDsimVar- Simulationsvariante- Returns:
- ArchiveTask
- See Also:
calcArchivTaskIndex(long,long,long, int, int)
-
getArchiveSettingsTask
Liefert den Task, der für die Bearbeitung der Archiveinstellungen verantwortlich ist. Dies ist notwendig, damit derArchiveManagerbeim Start einenArchiveSettingsTask.ArSSettingListenereinhängen und darauf warten kann, dass die Bearbeitung der Archiveinstellungen abgeschlossen ist. Das Archivsystem wartet beim Start auf die Archiv-Einstellungen, da es nicht sinnvoll ist, die ersten Sekunden mit Default-Werten loszulaufen.- Returns:
- Den Task, der für die Bearbeitung der Archiveinstellungen verantwortlich ist.
-
getSingleTask
Liefert den gewuenschten SingleTask (um etwa Listener einzuhängen)- Parameters:
taskIndex- Index der internen SingleTask-Liste- Returns:
- SingleTask
-
getArchiveDataReceiver
Die KlasseArchivConfigmeldet die zu archivierenden Daten mit dem Objekt als Empfaenger an, das von dieser Methode geliefert wird.- Returns:
- Empfaengerobjekt für zu archivierende Daten.
-
getDataAckSender
Die KlasseArchivConfigmeldet die Quittungen für die zu archivierenden Daten mit dem Objekt als Sender an, das von dieser Methode geliefert wird.- Returns:
- Senderobjekt für die Quittungen der zu archivierenden Daten.
-
setFreeDiskSpace
public void setFreeDiskSpace(long freeDiskSpace)Aktualisiert den freien Speicherplatz- Parameters:
freeDiskSpace- freier Speicherplatz in Bytes
-
getInitialCapacityOfOnlineQueues
public int getInitialCapacityOfOnlineQueues()Initiale Maximalgröße eines Ringpuffers für aktuelle Datensätze. Die MaximalGröße kann sich auf Kosten anderer Puffer ändern. Mit dynamischen PufferGrößen kann man Lastspitzen besser abfangen. -
getInitialCapacityOfRequestedQueue
public int getInitialCapacityOfRequestedQueue()Kapazität des Ringpuffers für nachgelieferte Datensätze -
getTotalCapacityOfOnlineQueues
public int getTotalCapacityOfOnlineQueues()Gesamtgröße (Summe) der Online-Queues -
getTotalCapacityOfRequestedQueues
public int getTotalCapacityOfRequestedQueues()Gesamtgröße (Summe) der Nachgefordert-Queues -
getOnlineQueueResizeBlockSize
public int getOnlineQueueResizeBlockSize()Größe der Blocks, in denen die Online-Queues vergrößert oder verkleinert werden- Returns:
-
setFastExit
public void setFastExit(boolean quickExit)Setzt, ob sich der InQueuesMgr schnell terminieren soll. Bei einer schnellen Terminierung wird nicht auf die Abarbeitugn aller Queues gewartet.- Parameters:
quickExit- true wenn schnell terminiert werden soll, sonst false
-
getReceivedCountOnline
public long getReceivedCountOnline()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()vongetArchiveDataReceiver()empfangenen Datensätze, egal ob diese archiviert werden oder nicht. Kann zur Test-Synchronisation verwendet werden.
-
getQueuedCountTotal
public long getQueuedCountTotal()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()Datensätze, die in eine Queue eingefügt wurden.
-
getQueuedCountOnline
public long getQueuedCountOnline()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()Online-Datensätze, die in eine Queue eingefügt wurden.
-
getQueuesCountRequested
public long getQueuesCountRequested()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()nachgeforderten Datensätze, die in eine Queue eingefügt wurden.
-
getFailedCountTotal
public long getFailedCountTotal()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()Datensätze, die nicht erfolgreich archiviert wurden
-
getSuccessCountTotal
public long getSuccessCountTotal()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()Datensätze, die erfolgreich archiviert wurden
-
getFailedCountOnline
public long getFailedCountOnline()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()Online-Datensätze, die nicht erfolgreich archiviert wurden
-
getSuccessCountOnline
public long getSuccessCountOnline()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()Online-Datensätze, die erfolgreich archiviert wurden
-
getFailedCountRequested
public long getFailedCountRequested()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()nachgeforderten Datensätze, die nicht erfolgreich archiviert wurden
-
getSuccessCountRequested
public long getSuccessCountRequested()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()nachgeforderten Datensätze, die erfolgreich archiviert wurden
-
getProcessedCountTotal
public long getProcessedCountTotal()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()Datensätze, die verarbeitet wurden
-
getProcessedCountOnline
public long getProcessedCountOnline()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()Online-Datensätze, die verarbeitet wurden
-
getProcessedCountRequested
public long getProcessedCountRequested()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()nachgeforderten Datensätze, die verarbeitet wurden
-
getCloseContainerSuccess
public long getCloseContainerSuccess()- Returns:
- Zahl aller seit dem Start oder letzten
resetDSCounter()erfolgreich verarbeiteten Close-Container-Datensätze. Kann zur Test-Synchronisation verwendet werden.
-