public class Meldungserzeugung extends Thread implements de.bsvrz.dav.daf.main.ClientReceiverInterface, de.bsvrz.dav.daf.main.ClientSenderInterface, de.bsvrz.dav.daf.main.config.InvalidationListener, LMSMeldungenListener, de.bsvrz.dav.daf.main.config.MutableSetChangeListener
| Modifier and Type | Class and Description |
|---|---|
private class |
Meldungserzeugung.MeldungenWorker
Worker-Thread.
|
private class |
Meldungserzeugung.MeldungListenerSync |
(package private) class |
Meldungserzeugung.MengeListener
Listener für Änderungen der Menge der RDS-Meldungen des
Landesmeldestelle.
|
Thread.State, Thread.UncaughtExceptionHandler| Modifier and Type | Field and Description |
|---|---|
private static String |
ATTRIBUTGRUPPE_PARAMETER
Attributgruppe der Kommunikationsparameter.
|
private de.bsvrz.dav.daf.main.config.DataModel |
config
Datenmodell der Konfiguration.
|
private boolean |
datenAngemeldet |
private de.bsvrz.dav.daf.main.ClientDavInterface |
dav
DaV Interface.
|
private de.bsvrz.sys.funclib.debug.Debug |
debug
Logger für Debug-Ausgaben.
|
private de.bsvrz.dav.daf.main.config.ConfigurationObject |
lms
Objektreferenz auf das Objekt vom Typ "typ.tic3LandesMeldeStelle".
|
private LMSParameter |
lmsParameter
Die aktuellen Parameter.
|
private Map<String,ExterneMeldung> |
meldungenTIC3
Die Liste der aktuellen TIC3-Meldungen.
|
private Map<String,TMCMeldung> |
meldungenTMC
Die Liste der aktuellen TMC-Meldungen.
|
private LinkedBlockingQueue<List<ExterneMeldung>> |
meldungsAuftraege
Enthält die empfangenen Meldungen.
|
private Meldungsdekodierer |
meldungsdekodierer
Meldungsdekodierer.
|
private de.bsvrz.dav.daf.main.config.MutableSet |
meldungsmengeTIC3
Die Menge der TIC3-Meldungen der Landesmeldestelle.
|
private de.bsvrz.dav.daf.main.config.MutableSet |
meldungsmengeTMC
Die Menge der TMC-Meldungen der Landesmeldestelle.
|
private boolean |
mitValidierung |
private de.bsvrz.dav.daf.main.config.DynamicObjectType |
objektTypExterneMeldungen
Objekttyp der TIC3-Meldungen.
|
private de.bsvrz.dav.daf.main.config.DynamicObjectType |
objektTypTMC
Objekttyp der TMC-Meldungen.
|
private de.bsvrz.dav.daf.main.DataDescription |
paramEmpfang
Datenbeschreibung, mit der Parameter empfangen werden.
|
private boolean |
parameterEmpfangen |
private boolean |
run
Run-Flag.
|
private de.bsvrz.sys.funclib.dynobj.DynamischeObjekte |
vdo
Klasse zum Verwalten dynamischer Objekte.
|
private Meldungserzeugung.MeldungenWorker |
worker |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY| Constructor and Description |
|---|
Meldungserzeugung(de.bsvrz.dav.daf.main.ClientDavInterface dav,
de.bsvrz.dav.daf.main.config.ConfigurationObject lms,
boolean mitValidierung)
Konstruktor.
|
| Modifier and Type | Method and Description |
|---|---|
private String |
createOrUpdateTIC3Meldung(ExterneMeldung meldung) |
private String |
createOrUpdateTMCMeldung(ExterneMeldung meldung) |
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription,
byte state) |
void |
empfangen(List<ExterneMeldung> externemeldungen)
Diese Methode wird aufgerufen, wenn neu empfangene Meldungsdaten von der LMS
zur Verfügung stehen.
|
(package private) void |
entfernenMeldung(de.bsvrz.dav.daf.main.config.SystemObject so)
Entfernt eine Meldung aus der Meldungsliste.
|
private void |
handleTIC3SetUpdate(de.bsvrz.dav.daf.main.config.SystemObject[] addedObjects,
de.bsvrz.dav.daf.main.config.SystemObject[] removedObjects) |
private void |
handleTMCSetUpdate(de.bsvrz.dav.daf.main.config.SystemObject[] addedObjects,
de.bsvrz.dav.daf.main.config.SystemObject[] removedObjects) |
void |
hinzufuegenMeldung(de.bsvrz.dav.daf.main.config.SystemObject objekt)
Fügt eine Meldung zur Meldungsliste hinzu.
|
void |
invalidObject(de.bsvrz.dav.daf.main.config.DynamicObject dynamicObject) |
private boolean |
isEmpfangAktiv() |
private boolean |
isMeldungZuLoeschen(de.bsvrz.dav.daf.main.config.SystemObject so)
Prüft, ob die Meldung zu löschen ist.
|
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
private void |
loescheMeldungen(String menge,
String typ,
String name,
boolean mitParamCheck) |
private void |
meldungenLoeschen() |
private void |
meldungenLoeschen(List<de.bsvrz.dav.daf.main.config.SystemObject> loeschen,
de.bsvrz.dav.daf.main.config.MutableSet menge) |
private boolean |
parameterGueltig() |
void |
run() |
void |
stopp()
Stoppt den Thread.
|
protected void |
subscribeData()
Anmeldung aller Daten am DAV.
|
void |
update(de.bsvrz.dav.daf.main.config.MutableSet set,
de.bsvrz.dav.daf.main.config.SystemObject[] addedObjects,
de.bsvrz.dav.daf.main.config.SystemObject[] removedObjects) |
void |
update(de.bsvrz.dav.daf.main.ResultData[] results) |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yieldprivate static final String ATTRIBUTGRUPPE_PARAMETER
private final de.bsvrz.sys.funclib.debug.Debug debug
private de.bsvrz.dav.daf.main.ClientDavInterface dav
private de.bsvrz.dav.daf.main.config.DataModel config
private de.bsvrz.dav.daf.main.config.ConfigurationObject lms
private Map<String,ExterneMeldung> meldungenTIC3
private Map<String,TMCMeldung> meldungenTMC
private de.bsvrz.dav.daf.main.config.MutableSet meldungsmengeTMC
private de.bsvrz.dav.daf.main.config.MutableSet meldungsmengeTIC3
private final LMSParameter lmsParameter
private de.bsvrz.dav.daf.main.DataDescription paramEmpfang
private Meldungsdekodierer meldungsdekodierer
private boolean run
private de.bsvrz.sys.funclib.dynobj.DynamischeObjekte vdo
private de.bsvrz.dav.daf.main.config.DynamicObjectType objektTypTMC
private de.bsvrz.dav.daf.main.config.DynamicObjectType objektTypExterneMeldungen
private boolean mitValidierung
private boolean parameterEmpfangen
private LinkedBlockingQueue<List<ExterneMeldung>> meldungsAuftraege
private Meldungserzeugung.MeldungenWorker worker
private boolean datenAngemeldet
public Meldungserzeugung(de.bsvrz.dav.daf.main.ClientDavInterface dav,
de.bsvrz.dav.daf.main.config.ConfigurationObject lms,
boolean mitValidierung)
dav - Datenverteiler-Verbindunglms - LandesmeldestellemitValidierung - Schame-Validierung ausführen oder nichtprivate String createOrUpdateTIC3Meldung(ExterneMeldung meldung) throws TMCException
TMCExceptionprivate void meldungenLoeschen(List<de.bsvrz.dav.daf.main.config.SystemObject> loeschen, de.bsvrz.dav.daf.main.config.MutableSet menge)
private String createOrUpdateTMCMeldung(ExterneMeldung meldung) throws TMCException
TMCExceptionpublic 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.ClientSenderInterfacevoid entfernenMeldung(de.bsvrz.dav.daf.main.config.SystemObject so)
so - Systemobjekt der Meldungpublic void hinzufuegenMeldung(de.bsvrz.dav.daf.main.config.SystemObject objekt)
objekt - Systemobjekt der Meldungpublic 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.ClientSenderInterfaceprivate boolean parameterGueltig()
private void meldungenLoeschen()
public void stopp()
protected void subscribeData()
throws TIC3Exception
TIC3Exception - bei Ausnahmenpublic void update(de.bsvrz.dav.daf.main.ResultData[] results)
update in interface de.bsvrz.dav.daf.main.ClientReceiverInterfacepublic void invalidObject(de.bsvrz.dav.daf.main.config.DynamicObject dynamicObject)
invalidObject in interface de.bsvrz.dav.daf.main.config.InvalidationListenerpublic void empfangen(List<ExterneMeldung> externemeldungen)
LMSMeldungenListenerempfangen in interface LMSMeldungenListenerexternemeldungen - Liste mit neuen Meldungenprivate void handleTMCSetUpdate(de.bsvrz.dav.daf.main.config.SystemObject[] addedObjects,
de.bsvrz.dav.daf.main.config.SystemObject[] removedObjects)
private void handleTIC3SetUpdate(de.bsvrz.dav.daf.main.config.SystemObject[] addedObjects,
de.bsvrz.dav.daf.main.config.SystemObject[] removedObjects)
private void loescheMeldungen(String menge, String typ, String name, boolean mitParamCheck)
private boolean isMeldungZuLoeschen(de.bsvrz.dav.daf.main.config.SystemObject so)
Es werden alle Meldungen gelöscht, die keine Parameter besitzen.
so - SystemObjecttrue, wenn zu löschen, sonst falsepublic void update(de.bsvrz.dav.daf.main.config.MutableSet set,
de.bsvrz.dav.daf.main.config.SystemObject[] addedObjects,
de.bsvrz.dav.daf.main.config.SystemObject[] removedObjects)
update in interface de.bsvrz.dav.daf.main.config.MutableSetChangeListenerprivate boolean isEmpfangAktiv()
Copyright © 2017 BitCtrl Systems GmbH. All rights reserved.