public class InQueuesMgr.ArchiveDataReceiver extends InQueuesMgr.DataReceiver
Modifier and Type | Field and Description |
---|---|
private long[] |
_statisticLastCacheCounts |
private long |
_statisticLastTotalFailedDataSetCount |
private long |
_statisticLastTotalQueuedDataSetCount |
private long |
_statisticLastTotalReceivedDataSetCount |
private long |
_statisticLastTotalSuccessedDataSetCount |
private long |
_statisticNextPrintTime |
private boolean |
firstData
Wird auf false gesetzt, nachdem der erste Datensatz empfangen wurde.
|
private boolean |
isSuspended |
static String |
MSG_PID_ATBACKSTEP_RESUME |
static String |
MSG_PID_ATBACKSTEP_SUSPEND |
static String |
MSG_PID_ATFWSTEP_RESUME |
static String |
MSG_PID_ATFWSTEP_SUSPEND |
private boolean |
resumeArchMessageSentBS |
private boolean |
resumeArchMessageSentFS |
private static long |
STATISTIC_PRINT_TIME_INTERVAL |
private boolean |
suspendArchMessageSentBS |
private boolean |
suspendArchMessageSentFS |
private long |
tMaxATimeForwardStep
max.
|
Constructor and Description |
---|
InQueuesMgr.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) |
update
public static final String MSG_PID_ATBACKSTEP_SUSPEND
public static final String MSG_PID_ATBACKSTEP_RESUME
public static final String MSG_PID_ATFWSTEP_SUSPEND
public static final String MSG_PID_ATFWSTEP_RESUME
private boolean suspendArchMessageSentBS
private boolean resumeArchMessageSentBS
private boolean suspendArchMessageSentFS
private boolean resumeArchMessageSentFS
private boolean isSuspended
private boolean firstData
private long tMaxATimeForwardStep
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[] _statisticLastCacheCounts
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)
aTime
- aktuelle ArchivzeitlastArchiveTime
- private void putDataInQueue(long archiveTime, ResultData resultData)
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)
tMax
- max. erlaubter Sprung (in Sekunden)public long getTMaxATimeForwardStep()