de.bsvrz.dav.daf.main.ClientReceiverInterface
, de.bsvrz.dav.daf.main.ClientSenderInterface
, de.bsvrz.sys.funclib.application.StandardApplication
public class AbfragePufferdaten
extends java.lang.Object
implements de.bsvrz.sys.funclib.application.StandardApplication, de.bsvrz.dav.daf.main.ClientReceiverInterface, de.bsvrz.dav.daf.main.ClientSenderInterface
Modifier and Type | Field | Description |
---|---|---|
protected static java.lang.String |
P_ABFRAGE_MODUL |
Ob alle DEs online sein muessen, damit man eine Pufferabfrage machen
kann.
|
protected static java.lang.String |
P_ALLE_ONLINE |
Ob alle DEs online sein muessen, damit man eine Pufferabfrage machen
kann.
|
protected static java.lang.String |
P_SM |
Parameter dem man erkennen soll SteuerModule und Konfigurationsbereiche
die verwaltet werden sollen.
|
protected static long |
ZEIT_TOLERANZ |
Wenn Zwei Zeitstempel fuer Abrufe innerhalb dieses Intervalls sind, dann
koennen wir sie als gleich betrachten, vermeidet 2 Abrufe in der selben
Zeit.
|
Constructor | Description |
---|---|
AbfragePufferdaten() |
Modifier and Type | Method | Description |
---|---|---|
void |
abmeldeGloFehler() |
Meldet sich von GloFehler Meldungen ab.
|
void |
aggregationStart() |
Startet die Aggregation von LZD.
|
void |
aggregiere() |
Stellt dem Wecker fuer die naechste Aggregation fest.
|
void |
anmeldeAbfrageModulParametrierung() |
Meldet sich online fuer die AbfrageModul Parametrierung an.
|
void |
anmeldeGloFehler() |
Anmeldung fuer Empfang von Globalen FehlerMeldungen.
|
void |
axlAlarm() |
Startet eine regelmaesige Axl Abfrage.
|
long |
convertAbsoluteEchtZeit(long zeit) |
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertAbsoluteVirtuelleZeit(long zeit) |
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertTimeoutIntervall(long intervall) |
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
convertZeitIntervall(long zeitIntervall) |
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
long |
currentTimeMillis() |
Wegen Test Zwecken wird es in vererbten Klassen ueberdeckt.
|
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription,
byte state) |
|
de.bsvrz.dav.daf.main.DataDescription |
erzeugeDatenBeschreibung(java.lang.String atg,
java.lang.String asp,
short var) |
Erzeugt eine DatenBeschreibung mit gegebenen Parameter als Strings.
|
static java.lang.String |
getAbfrageModul() |
Erfragt die PID des assoziierten Abfragemoduls.
|
long |
getAbrufIntervallAxl() |
Erfargt nach dem Abrufintervall fuer Axl Daten.
|
long |
getAbrufIntervallLve() |
Erfraget nach den Abrufintervall fuer Lve Daten.
|
static de.bsvrz.sys.funclib.dataIdentificationSettings.SettingsManager |
getArchivSettingsManager() |
liefert den aktiven Settingsmanager für den Archivdatensatz.
|
protected AbstraktDeVerwaltung |
getAxlDeVerwaltung() |
|
de.bsvrz.dav.daf.main.ClientDavInterface |
getDatenVerteiler() |
Erfragt eine Instanz des DAVs.
|
protected de.bsvrz.dav.daf.main.ClientDavInterface |
getDav() |
|
protected AbstraktDeVerwaltung |
getLveDeVerwaltung() |
|
de.bsvrz.sys.funclib.operatingMessage.MessageSender |
getnachrichtenSender() |
Liefert dem Nachrichtensender.
|
protected long |
getNaechsteAbfrageAxl() |
|
protected long |
getNaechsteAbfrageAxlNeu() |
|
protected long |
getNaechsteAbfrageLve() |
|
protected long |
getNaechsteAbfrageLveNeu() |
|
protected java.util.List<Station> |
getStationen() |
|
de.bsvrz.sys.funclib.bitctrl.dua.dfs.typen.SWETyp |
getSWETyp() |
Typ der SWE.
|
void |
initialize(de.bsvrz.dav.daf.main.ClientDavInterface connection) |
|
void |
initLveAxlVerwaltung() |
Wegen Testzwecken wird es ueberschrieben.
|
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
|
void |
lveAlarm() |
Startet eine regelmaesige Lve Abfrage.
|
static void |
main(java.lang.String[] args) |
Wird zum Start der Applikation aufgerufen.
|
void |
parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumente) |
|
static void |
printVerwendung() |
Anwendungsparameter.
|
void |
setAbrufPeriode(de.bsvrz.dav.daf.main.ResultData datei) |
Stellt die Abrufperiode fest, wird bei Aenderung der Parametrierung
gerufen.
|
protected void |
setAxlDeVerwaltung(AbstraktDeVerwaltung axlDeVerwaltung) |
|
void |
setGloFehler(de.bsvrz.dav.daf.main.ResultData datei) |
Stelt den Status des Objektes aus einer GloFehlermeldung fest.
|
protected void |
setLveDeVerwaltung(AbstraktDeVerwaltung lveDeVerwaltung) |
|
protected void |
setLzdAggregation(AggregatorVerwaltung lzdAggregation) |
|
void |
streamAbfrage(SBArchivAnfrageBearbeiter bearbeiter,
java.util.Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekte,
de.bsvrz.dav.daf.main.DataDescription datenBeschreibung,
boolean relative,
long intervalBeginnOderAnzahl,
long intervalEnde) |
Macht eine StreamAbfrage.
|
void |
update(de.bsvrz.dav.daf.main.ResultData[] results) |
protected static final java.lang.String P_SM
protected static final java.lang.String P_ALLE_ONLINE
protected static final java.lang.String P_ABFRAGE_MODUL
protected static final long ZEIT_TOLERANZ
public void parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumente) throws java.lang.Exception
parseArguments
in interface de.bsvrz.sys.funclib.application.StandardApplication
java.lang.Exception
public static void printVerwendung()
public void initialize(de.bsvrz.dav.daf.main.ClientDavInterface connection) throws java.lang.Exception
initialize
in interface de.bsvrz.sys.funclib.application.StandardApplication
java.lang.Exception
public static final java.lang.String getAbfrageModul()
null
,
wenn keines angegeben wurdepublic void initLveAxlVerwaltung()
public de.bsvrz.dav.daf.main.DataDescription erzeugeDatenBeschreibung(java.lang.String atg, java.lang.String asp, short var)
atg
- Atributgruppeasp
- Aspektvar
- Simulation Variantpublic void anmeldeAbfrageModulParametrierung()
public void anmeldeGloFehler()
public de.bsvrz.sys.funclib.operatingMessage.MessageSender getnachrichtenSender()
public void abmeldeGloFehler()
public void dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object, de.bsvrz.dav.daf.main.DataDescription dataDescription, byte state)
dataRequest
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
public boolean isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object, de.bsvrz.dav.daf.main.DataDescription dataDescription)
isRequestSupported
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
public void update(de.bsvrz.dav.daf.main.ResultData[] results)
update
in interface de.bsvrz.dav.daf.main.ClientReceiverInterface
public void streamAbfrage(SBArchivAnfrageBearbeiter bearbeiter, java.util.Collection<de.bsvrz.dav.daf.main.config.SystemObject> objekte, de.bsvrz.dav.daf.main.DataDescription datenBeschreibung, boolean relative, long intervalBeginnOderAnzahl, long intervalEnde)
bearbeiter
- Der Objekt, der die Antwort bearbeiten wird, muss
SBArchivAnfrageBearbeiter implementierenobjekte
- Die Objekte, an deren Daten wir nachfragen wollendatenBeschreibung
- Die DatenBeschreibung fuer die Datenrelative
- true, wenn die Abfrage relativ istintervalBeginnOderAnzahl
- Beginn des abfragenden Intervalls oder Anzahl der Datensaetze
bei relativen AbfragenintervalEnde
- Ende des abfrafenden Intervallspublic void setGloFehler(de.bsvrz.dav.daf.main.ResultData datei)
datei
- Datei mit atg.tlsGloFehler, die empfangen wurdepublic void setAbrufPeriode(de.bsvrz.dav.daf.main.ResultData datei)
datei
- Datei mit atg.abfrageModul, die empfangen wurdepublic void axlAlarm()
public void lveAlarm()
public static void main(java.lang.String[] args)
args
- Aufrufargumente der Applikationpublic de.bsvrz.sys.funclib.bitctrl.dua.dfs.typen.SWETyp getSWETyp()
public de.bsvrz.dav.daf.main.ClientDavInterface getDatenVerteiler()
public void aggregiere()
public void aggregationStart()
public long getAbrufIntervallAxl()
public long getAbrufIntervallLve()
public long currentTimeMillis()
public long convertZeitIntervall(long zeitIntervall)
zeitIntervall
- Virtueller ZeitIntervallpublic long convertTimeoutIntervall(long intervall)
intervall
- Virtueller Timeout Intervallpublic long convertAbsoluteEchtZeit(long zeit)
zeit
- Echter Zeitpunktpublic long convertAbsoluteVirtuelleZeit(long zeit)
zeit
- Virtueller Zeitpunktpublic static de.bsvrz.sys.funclib.dataIdentificationSettings.SettingsManager getArchivSettingsManager()
protected AbstraktDeVerwaltung getLveDeVerwaltung()
protected AbstraktDeVerwaltung getAxlDeVerwaltung()
protected void setLveDeVerwaltung(AbstraktDeVerwaltung lveDeVerwaltung)
protected void setAxlDeVerwaltung(AbstraktDeVerwaltung axlDeVerwaltung)
protected java.util.List<Station> getStationen()
protected long getNaechsteAbfrageLveNeu()
protected long getNaechsteAbfrageLve()
protected long getNaechsteAbfrageAxlNeu()
protected long getNaechsteAbfrageAxl()
protected void setLzdAggregation(AggregatorVerwaltung lzdAggregation)
protected de.bsvrz.dav.daf.main.ClientDavInterface getDav()