public class Meldungskodierer extends Thread implements de.bsvrz.dav.daf.main.ClientReceiverInterface, de.bsvrz.dav.daf.main.ClientSenderInterface, LMSFTPListener, de.bsvrz.dav.daf.main.config.InvalidationListener
Modifier and Type | Class and Description |
---|---|
(package private) class |
Meldungskodierer.MengeListener
Listener für Änderungen der Menge der TMC-Meldungen.
|
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
DebugLogger für Debug-Ausgaben.
|
private LMSFTPClient |
ftpclient
FTP-Client Thread.
|
private LMSKommunikationsstatus |
kommunikationsStatus
Der Kommunikationsstatus mit der Landesmeldestelle.
|
private long |
letzterVersand |
private de.bsvrz.dav.daf.main.config.ConfigurationObject |
lms
Objektreferenz auf das Objekt vom Typ "typ.landesMeldeStelle".
|
private LMSParameter |
lmsParameter
Parameter.
|
private Map<String,TMCMeldung> |
meldungen
Die Liste der zu versendenden Meldungen.
|
private de.bsvrz.dav.daf.main.DataDescription |
paramEmpfang
Datenbeschreibung, mit der Parameter empfangen werden.
|
private boolean |
parameterEmpfangen |
private de.bsvrz.dav.daf.main.DataDescription |
paramVersand
Datenbeschreibung, mit der Parameter versendet werden.
|
private boolean |
run
Run-Flag.
|
private Object |
runLock
Lock-Objekt.
|
private static String |
XML_ELEMENT_TIC_ROOT
Wurzelelement der TIC-Info Dateien.
|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
Meldungskodierer(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 |
bildeDateinamen()
Bildet den Dateinamen für eine zu versendende Datei.
|
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription,
byte state) |
private void |
datenAnmeldenDaV()
Meldet alle benötigten Daten am Datenverteiler an.
|
void |
empfangen(List<File> dateien)
Diese Methode wird aufgerufen, wenn neu empfangene Dateien 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.
|
void |
hinzufuegenMeldung(de.bsvrz.dav.daf.main.config.SystemObject objekt)
Füget eine Meldung zur Meldungsliste hinzu.
|
void |
invalidObject(de.bsvrz.dav.daf.main.config.DynamicObject dynamicObject) |
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
private boolean |
isVersandAktiv() |
void |
kommunikationsStatus(LMSKommunikationsstatus status)
Diese Methode wird aufgerufen, wenn eine Änderung des
Kommunikationszustandes zur LMS erkannt wird.
|
void |
laufendeNummerAktualisieren()
Aktualisiert die laufende Nummer der Kommunikationsparameter.
|
void |
run() |
void |
stopp()
Stoppt den Thread.
|
private void |
ueberpruefeMeldungen()
Überproüft alle Meldungen auf einen notwendigen Versand.
|
void |
update(de.bsvrz.dav.daf.main.ResultData[] results) |
void |
versendeMeldungen(File datei,
List<TMCMeldung> neuemeldungen)
Versendet eine Liste von Meldungen.
|
private void |
versendeMeldungen(List<TMCMeldung> versenden,
boolean spontan) |
void |
versendet(List<File> dateien,
LMSKommunikationsstatus status)
Diese Methode wird aufgerufen, wenn Dateien zur LMS übertragen
wurden.
|
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 static final String XML_ELEMENT_TIC_ROOT
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,TMCMeldung> meldungen
private LMSFTPClient ftpclient
private de.bsvrz.dav.daf.main.DataDescription paramEmpfang
private de.bsvrz.dav.daf.main.DataDescription paramVersand
private final LMSParameter lmsParameter
private LMSKommunikationsstatus kommunikationsStatus
private final Object runLock
private boolean datenAngemeldet
private boolean run
private boolean parameterEmpfangen
private long letzterVersand
public Meldungskodierer(de.bsvrz.dav.daf.main.ClientDavInterface dav, de.bsvrz.dav.daf.main.config.ConfigurationObject lms, boolean mitValidierung)
dav
- Datenverteilerverbindunglms
- das die Landesmeldestelle repräsentierende SystemobjektmitValidierung
- legt fest, ob die empfangenen Dateien gegen das Schema
validiert werden sollenprivate String bildeDateinamen()
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
private void datenAnmeldenDaV()
public void empfangen(List<File> dateien)
LMSFTPListener
empfangen
in interface LMSFTPListener
dateien
- Liste mit neuen Dateienvoid entfernenMeldung(de.bsvrz.dav.daf.main.config.SystemObject so)
so
- zugeordnetes Systemobjektpublic void hinzufuegenMeldung(de.bsvrz.dav.daf.main.config.SystemObject objekt) throws TIC3Exception
objekt
- Systemobjekt der MeldungTIC3Exception
- bei Ausnahmenpublic 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 kommunikationsStatus(LMSKommunikationsstatus status)
LMSFTPListener
kommunikationsStatus
in interface LMSFTPListener
status
- der Kommunikationsstatuspublic void laufendeNummerAktualisieren()
public void stopp()
private void ueberpruefeMeldungen() throws TIC3Exception
TIC3Exception
- bei Ausnahmenprivate boolean isVersandAktiv()
private void versendeMeldungen(List<TMCMeldung> versenden, boolean spontan) throws TIC3Exception
TIC3Exception
public void update(de.bsvrz.dav.daf.main.ResultData[] results)
update
in interface de.bsvrz.dav.daf.main.ClientReceiverInterface
public void versendeMeldungen(File datei, List<TMCMeldung> neuemeldungen) throws TIC3Exception
datei
- Date zum Versand der Meldungenneuemeldungen
- zu versendende MeldungenTIC3Exception
- bei Ausnahmenpublic void versendet(List<File> dateien, LMSKommunikationsstatus status)
LMSFTPListener
versendet
in interface LMSFTPListener
dateien
- Liste mit versendeten Dateienstatus
- Status des Versandespublic void invalidObject(de.bsvrz.dav.daf.main.config.DynamicObject dynamicObject)
invalidObject
in interface de.bsvrz.dav.daf.main.config.InvalidationListener
Copyright © 2017 BitCtrl Systems GmbH. All rights reserved.