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 |
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, yield
private 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
TMCException
private 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
TMCException
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
void 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.ClientSenderInterface
private 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.ClientReceiverInterface
public void invalidObject(de.bsvrz.dav.daf.main.config.DynamicObject dynamicObject)
invalidObject
in interface de.bsvrz.dav.daf.main.config.InvalidationListener
public void empfangen(List<ExterneMeldung> externemeldungen)
LMSMeldungenListener
empfangen
in interface LMSMeldungenListener
externemeldungen
- 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
- SystemObject
true
, wenn zu löschen, sonst false
public 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.MutableSetChangeListener
private boolean isEmpfangAktiv()
Copyright © 2017 BitCtrl Systems GmbH. All rights reserved.