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.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()
public void setTMaxATimeForwardStep(long tMaxSeconds)
Setzt den maximal erlaubten Vorwaertssprung der Archivzeit.
tMax
- max. erlaubter Sprung (in Sekunden)public long getTMaxATimeForwardStep()