public class InQueuesMgr.ArchiveDataReceiver extends InQueuesMgr.DataReceiver
Empfaengerklasse für Archivdaten
Constructor and Description |
---|
ArchiveDataReceiver() |
Modifier and Type | Method and Description |
---|---|
long |
getTMaxATimeForwardStep() |
boolean |
mustSuspendQueries() |
void |
processData(ResultData rd) |
private void |
putDataInQueue(long archiveTime,
ResultData resultData)
Legt das Datum in die passende Warteschlange.
|
private void |
sendArchiveResumeMsgBS(long aTime) |
private void |
sendArchiveResumeMsgFS(long aTime) |
private void |
sendArchiveSuspendMsgBS(long aTime) |
private void |
sendArchiveSuspendMsgFS(long aTime) |
void |
setTMaxATimeForwardStep(long tMaxSeconds)
Setzt den maximal erlaubten Vorwaertssprung der Archivzeit.
|
private boolean |
testForArchiveTimeBackstep(long aTime,
long lastArchiveTime)
Prueft ob ein Ruecksprung der Archivzeit aufgetreten ist und sendet entsprechende Betriebsmeldungen.
|
private boolean |
testForArchiveTimeForwardStep(long aTime,
long lastArchiveTime) |
void |
update(ResultData[] rds)
Aktualisierungsmethode, die nach Empfang eines angemeldeten Datensatzes von den Datenverteiler-Applikationsfunktionen aufgerufen wird.
|
public static final java.lang.String MSG_PID_ATBACKSTEP_SUSPEND
public static final java.lang.String MSG_PID_ATBACKSTEP_RESUME
public static final java.lang.String MSG_PID_ATFWSTEP_SUSPEND
public static final java.lang.String MSG_PID_ATFWSTEP_RESUME
private boolean suspendArchMessageSentBS
private boolean resumeArchMessageSentBS
private boolean suspendArchMessageSentFS
private boolean resumeArchMessageSentFS
private final boolean isSuspended
private boolean firstData
Wird auf false gesetzt, nachdem der erste Datensatz empfangen wurde. Wird verwendet, damit Vorwärtssprungs auch nach einem Neustart ses Archivsystems korrekt erkannt wird
private long tMaxATimeForwardStep
max. Archivzeitsprung vorwaerts (siehe TAnfArS 5.1.2.4.3.3)
private static final long STATISTIC_PRINT_TIME_INTERVAL
private long _statisticNextPrintTime
private long _statisticLastTotalReceivedDataSetCount
private long _statisticLastTotalQueuedDataSetCount
private long _statisticLastTotalSuccessedDataSetCount
private long _statisticLastTotalFailedDataSetCount
private long _statisticLastTotalQueuedDataSetCountRequested
private long _statisticLastTotalSuccessedDataSetCountRequested
private long _statisticLastTotalFailedDataSetCountRequested
private long[] _statisticLastCacheCounts
public void update(ResultData[] rds)
de.bsvrz.dav.daf.main.ClientReceiverInterface
update
in interface ClientReceiverInterface
update
in class InQueuesMgr.DataReceiver
rds
- Feld mit den empfangenen Ergebnisdatensätzen.public void processData(ResultData rd)
processData
in class InQueuesMgr.DataReceiver
public boolean mustSuspendQueries()
private boolean testForArchiveTimeForwardStep(long aTime, long lastArchiveTime)
private boolean testForArchiveTimeBackstep(long aTime, long lastArchiveTime)
Prueft ob ein Ruecksprung der Archivzeit aufgetreten ist und sendet entsprechende Betriebsmeldungen.
aTime
- aktuelle ArchivzeitlastArchiveTime
- private void putDataInQueue(long archiveTime, ResultData resultData)
Legt das Datum in die passende Warteschlange. Falls die voll ist, wird einmal eine Log-Message ausgegeben. Wenn sie nicht mehr voll ist, wird ebenfalls einmal eine Log-Message ausgegeben.
archiveTime
- Archivzeit des zu archivierenden DatumsresultData
- zu archivierendes Datumprivate void sendArchiveSuspendMsgFS(long aTime)
private void sendArchiveResumeMsgFS(long aTime)
private void sendArchiveSuspendMsgBS(long aTime)
private void sendArchiveResumeMsgBS(long aTime)
public void setTMaxATimeForwardStep(long tMaxSeconds)
Setzt den maximal erlaubten Vorwaertssprung der Archivzeit.
tMax
- max. erlaubter Sprung (in Sekunden)public long getTMaxATimeForwardStep()