public final class KzdTestSender extends TimerTask implements de.bsvrz.sys.funclib.application.StandardApplication, de.bsvrz.dav.daf.main.ClientSenderInterface
Modifier and Type | Field and Description |
---|---|
private Timer |
checkTimer |
private Random |
dataSource |
private long |
delay
Intervall, in dem neue Daten erzeugt werden.
|
private de.bsvrz.dav.daf.main.DataDescription |
descKurzzeitDaten |
private ArrayList<Integer[]> |
fileData |
private int |
idxData |
private static Logger |
LOGGER
der Logger.
|
private Collection<de.bsvrz.dav.daf.main.config.SystemObject> |
objektListe
Liste aller Fahrstreifen mit ihrem aktuellen Verbindungszustand.
|
private long |
startZeit |
private String |
typPid
die PID des verwendeten Datentyps.
|
private boolean |
useFileData
true, wenn Testdaten aus einer Datei erzeugt werden sollen.
|
private de.bsvrz.dav.daf.main.ClientDavInterface |
verbindung
verwendete Datenverteilerverbindung.
|
Modifier | Constructor and Description |
---|---|
private |
KzdTestSender()
Standardkonstruktor.
|
Modifier and Type | Method and Description |
---|---|
private de.bsvrz.dav.daf.main.Data |
buildData(int qKfz,
int qLkw,
int vPkw,
int vLkw,
int belegung)
Methode um einen Datensatz zu erzeugen.
|
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription,
byte state) |
private de.bsvrz.dav.daf.main.Data |
getTestDatenFromFile()
liefert die Testdaten aus einer Datei.
|
private de.bsvrz.dav.daf.main.Data |
getVerkehrsDaten()
liefert einen Satz Verkehrsdaten.
|
void |
initialize(de.bsvrz.dav.daf.main.ClientDavInterface dav) |
private void |
initWithFile(String file)
Initialisiert den KzdSender mit Daten aus dem übergebenen File.
|
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
static void |
main(String[] args)
Die Hauptfunktion des Observers.
|
void |
parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumentList) |
void |
run()
Prüft die Verfügbarkeit von Kurzzeitdaten aller Fahrstreifen
und sendet für die Stationen, die länger als X Minuten keine KZD empfangen haben eine Warnung an die BMV. |
cancel, scheduledExecutionTime
private static final Logger LOGGER
private final Collection<de.bsvrz.dav.daf.main.config.SystemObject> objektListe
private de.bsvrz.dav.daf.main.DataDescription descKurzzeitDaten
private final Timer checkTimer
private final Random dataSource
private long startZeit
private int idxData
private boolean useFileData
private long delay
private de.bsvrz.dav.daf.main.ClientDavInterface verbindung
private String typPid
public void run()
public void initialize(de.bsvrz.dav.daf.main.ClientDavInterface dav)
initialize
in interface de.bsvrz.sys.funclib.application.StandardApplication
public void parseArguments(de.bsvrz.sys.funclib.commandLineArgs.ArgumentList argumentList) throws Exception
parseArguments
in interface de.bsvrz.sys.funclib.application.StandardApplication
Exception
private void initWithFile(String file) throws Exception
file
- der Name des FilesException
- Initialisierung fehlgeschlagenpublic static void main(String[] args)
args
- Programm-Argumentepublic 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
private de.bsvrz.dav.daf.main.Data getVerkehrsDaten() throws Exception
Exception
- es konnten keine Daten ermittelt werdenprivate de.bsvrz.dav.daf.main.Data getTestDatenFromFile() throws Exception
Exception
private de.bsvrz.dav.daf.main.Data buildData(int qKfz, int qLkw, int vPkw, int vLkw, int belegung)
qKfz
- die Anzahl der KfzqLkw
- die Anzahl der LkwvPkw
- die Geschwindigkeit der PkwvLkw
- die Geschwindigkeit der Lkwbelegung
- die BelegungCopyright © 2017 BitCtrl Systems GmbH. All rights reserved.