|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.ars.ars.mgmt.InQueuesMgr.DataReceiver
de.bsvrz.ars.ars.mgmt.InQueuesMgr.ArchiveDataReceiver
public class InQueuesMgr.ArchiveDataReceiver
Empfaengerklasse fuer Archivdaten
Field Summary | |
---|---|
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 Summary | |
---|---|
InQueuesMgr.ArchiveDataReceiver()
|
Method Summary | |
---|---|
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)
|
Methods inherited from class de.bsvrz.ars.ars.mgmt.InQueuesMgr.DataReceiver |
---|
update |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
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
Constructor Detail |
---|
public InQueuesMgr.ArchiveDataReceiver()
Method Detail |
---|
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()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |