public class InQueuesMgr.ArchiveDataReceiver extends InQueuesMgr.DataReceiver
Empfaengerklasse für Archivdaten
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
MSG_PID_ATBACKSTEP_RESUME |
static java.lang.String |
MSG_PID_ATBACKSTEP_SUSPEND |
static java.lang.String |
MSG_PID_ATFWSTEP_RESUME |
static java.lang.String |
MSG_PID_ATFWSTEP_SUSPEND |
| Constructor and Description |
|---|
ArchiveDataReceiver() |
| Modifier and Type | Method and Description |
|---|---|
long |
getTMaxATimeForwardStep() |
boolean |
mustSuspendQueries() |
void |
processData(ResultData rd) |
void |
setTMaxATimeForwardStep(long tMaxSeconds)
Setzt den maximal erlaubten Vorwaertssprung der Archivzeit.
|
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
public void update(ResultData[] rds)
de.bsvrz.dav.daf.main.ClientReceiverInterfaceupdate in interface ClientReceiverInterfaceupdate in class InQueuesMgr.DataReceiverrds - Feld mit den empfangenen Ergebnisdatensätzen.public void processData(ResultData rd)
processData in class InQueuesMgr.DataReceiverpublic boolean mustSuspendQueries()
public void setTMaxATimeForwardStep(long tMaxSeconds)
Setzt den maximal erlaubten Vorwaertssprung der Archivzeit.
tMax - max. erlaubter Sprung (in Sekunden)public long getTMaxATimeForwardStep()