|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.sys.startstopp.prozessvew.DaVKommunikation
public class DaVKommunikation
Klasse zur Abhandlung der Kommunikation mit dem DaV. Die Klasse wird als Singelton ausgelegt.
Nested Class Summary | |
---|---|
private class |
DaVKommunikation.AngemeldeterEmpfaenger
|
private class |
DaVKommunikation.AngemeldeterSender
|
private static class |
DaVKommunikation.Inner
Geschachtelte Innere Klasse (wird verwendet um zu garantieren, dass wirklich nur eine Instanz der Klasse angelegt wird). |
Field Summary | |
---|---|
private static java.lang.StringBuilder |
_applicationLabel
Die ApplikationsKennung wird hier gespeichert. |
private static java.lang.String |
_applicationName
Der Name der Applikation, die den StandardApplicationRunner nutzt. |
private boolean |
_debugAnmelde
Debug Möglichkeit |
private boolean |
_debugFertigMeldung
Debug Möglichkeit |
private static de.bsvrz.sys.funclib.debug.Debug |
logger
Debug |
boolean |
m_angemeldet
Kennung ob StartStopp an einem DaV angemeldet ist |
private java.util.Vector<DaVKommunikation.AngemeldeterEmpfaenger> |
m_angemeldeteEmpfaenger
Liste mit den angemeldeten Empfängern. |
private java.util.Vector<DaVKommunikation.AngemeldeterSender> |
m_angemeldeteSender
Liste mit den angemeldeten Sendern. |
de.bsvrz.dav.daf.main.ClientDavInterface |
m_connection
Verbindung zum DaV |
de.bsvrz.dav.daf.main.ClientDavInterface |
m_connectionFuerImmer
Verbindung zum DaV (Grundlage für alle folgenden Verbindungen) |
private java.util.HashMap<java.lang.Long,java.lang.Integer> |
m_listeDavApplikationen
Liste mit den IDs der am Dav angemeldeten Applikationen |
private java.lang.String |
m_pidRechner
Pid des Rechners |
private boolean |
m_sendeProzessInfo
Merker ob die Attributgruppe "atg.prozessInfo" gesendet werden darf |
private boolean |
m_sendeStartStoppInfo
Merker ob die Attributgruppe "atg.startStoppInfo" gesendet werden darf |
(package private) static boolean |
m_verbunden
Kennung ob StartStopp mit einem DaV verbunden ist |
private java.util.List<java.lang.Long> |
m_warteApplikationsFertigmeldung
Liste der Applikationen, bei denen noch auf die Attributgruppe "atg.applikationsFertigmeldung" gewartet wird. |
private java.util.HashMap<java.lang.Long,java.lang.String> |
m_zuordnungIdZuInkarnationen
Liste mit der Zuordnung IDs zu Inkarnationsnamen der am Dav angemeldeten Applikationen |
private static long |
serialVersionUID
|
Fields inherited from interface de.bsvrz.dav.daf.main.ClientSenderInterface |
---|
START_SENDING, STOP_SENDING, STOP_SENDING_NO_RIGHTS, STOP_SENDING_NOT_A_VALID_SUBSCRIPTION |
Constructor Summary | |
---|---|
private |
DaVKommunikation()
Privater Konstruktor der Klasse (Singelton) |
Method Summary | |
---|---|
private void |
_sendeStartStoppinfo()
Eigentliche Methode zum Senden der Attributgruppe "atg.startStoppInfo". |
void |
abmeldeLeseDaV(long objId,
java.lang.String atgPid,
java.lang.String aspPid)
Methode die das Objekt objId beim Datenverteiler abmeldet zum Lesen der Attibutgruppe atgPid unter dem Aspekt aspPid. |
void |
abmeldeSendeDaV(long objId,
java.lang.String atgPid,
java.lang.String aspPid)
Methode die das Objekt objId beim Datenverteiler abmeldet zum Senden der Attibutgruppe atgPid unter dem Aspekt aspPid. |
void |
allesAbmelden()
Alle zuvor angemeldeten Empfänger, Senken, Sender und Quellen abmelden. |
void |
anmeldeDaV()
Methode meldet sich am DaV an zum: - Senden "atg.prozessInfo" "asp.zustand" - Lesen "atg.startStoppAnfrage", "asp.anfrage" - Lesen "atg.prozessInfo", "asp.zustand" (für jeden Rechner der in der Klasse "GlobaleDaten" definiert ist |
private void |
anmeldeLeseDaV(long objId,
java.lang.String atgPid,
java.lang.String aspPid,
de.bsvrz.dav.daf.main.ReceiverRole role)
Methode die das Objekt mit der ID objId beim Datenverteiler anmeldet zum Lesen der Attibutgruppe atgPid unter dem Aspekt aspPid. |
private void |
anmeldeLeseDaV(java.lang.String objPid,
java.lang.String atgPid,
java.lang.String aspPid,
de.bsvrz.dav.daf.main.ReceiverRole role)
Methode die das Objekt mit der PID objPid beim Datenverteiler anmeldet zum Lesen der Attibutgruppe atgPid unter dem Aspekt aspPid. |
private void |
anmeldeLeseRechner()
Methode zum Anmelden der Attributgruppe "atg.prozessInfo" am DaV. |
de.bsvrz.dav.daf.main.DataDescription |
anmeldeSendeDaV(long objId,
java.lang.String atgPid,
java.lang.String aspPid,
de.bsvrz.dav.daf.main.SenderRole role)
Methode die das Objekt mit der ID objId beim Datenverteiler anmeldet zum Senden der Attibutgruppe atgPid unter dem Aspekt aspPid. |
de.bsvrz.dav.daf.main.DataDescription |
anmeldeSendeDaV(java.lang.String objPid,
java.lang.String atgPid,
java.lang.String aspPid,
de.bsvrz.dav.daf.main.SenderRole role)
Methode die das Objekt mit der PID objPid beim Datenverteiler anmeldet zum Senden der Attibutgruppe atgPid unter dem Aspekt aspPid. |
boolean |
baueVerbindungDaVAuf()
Methode baut Verbindung zum DaV auf |
private java.lang.String |
bestimmeIpRechner(java.lang.String pidRechner)
Methode bestimmt die IP-Adresse eines Rechners, dessen PID übergeben wird. |
private java.util.List<java.lang.String> |
bestimmeObjekte(java.lang.String objPid)
Methode zum Bestimmen der Objekte, die zu einer bestimmten PID gehören (z.B. typ.de) |
private java.lang.String |
bestimmePidRechner(int art,
java.lang.String value)
Methode bestimmt die PID zu einem Rechner. |
java.lang.String |
bestimmePidRechnerByHost(java.lang.String host)
Bestimmt die Pid eines Rechners aufgrund des übergebenen Rechnernamens. |
java.lang.String |
bestimmePidRechnerByIp(java.lang.String ip)
Bestimmt die Pid eines Rechners aufgrund der übergebenen TCP/IP-Adresse |
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject arg0,
de.bsvrz.dav.daf.main.DataDescription arg1,
byte arg2)
|
private de.bsvrz.dav.daf.main.Data |
erstelleProzessInfo()
Methode zum Erstellen der Attributgruppe "atg.prozessInfo" |
private de.bsvrz.dav.daf.main.Data |
erstelleStartStoppInfo()
Methode zum Erstellen der Attributgruppe "atg.startStoppInfo" |
private java.lang.String |
exceptionMeldungBestimmen(java.lang.Exception exception)
Informationen einer Exception in einen String packen. |
java.util.Vector<DaVKommunikation.AngemeldeterEmpfaenger> |
getAngemeldeteEmpfaenger()
|
java.util.Vector<DaVKommunikation.AngemeldeterSender> |
getAngemeldeteSender()
|
de.bsvrz.dav.daf.main.ClientDavInterface |
getConnection()
Holt die aktuelle Datenverteilerverbindung. |
de.bsvrz.dav.daf.main.ClientDavInterface |
getConnectionFuerImmer()
Holt die zu Grunde liegende Datenverteilerverbindung. |
static DaVKommunikation |
getInstanz()
Methode liefert die einzige Instanz der Klasse |
java.lang.String |
getPidRechner()
Methode liefert die Variable pidRechner zurück |
boolean |
isInkarnationAmDaVAngemeldet(java.lang.String inkarnation)
Methode liefert Informationen darüber, ob eine Applikation mit dem Inkarnationsnamen "inkarnation" am DaV angemeldet ist oder nicht. |
boolean |
isPidRechnerGueltig(java.lang.String pidRechner)
Methode prüft ob eine übergeben Pid eine gültige Pid eines Objekts vom Typ Rechner ist |
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject arg0,
de.bsvrz.dav.daf.main.DataDescription arg1)
|
boolean |
istVerbunden()
Rückgabe ob die Verbindung zum DaV steht |
private boolean |
pruefeUsv(java.lang.String pidUsv)
Methode zum Prüfen ob die USV mit der Pid pidUSV existiert |
void |
sendeBetriebsmeldung(java.lang.String text)
Methode zum Absetzen einer Betriebsmeldung an den Datenverteiler |
void |
sendeProzessInfo()
Methode zum Senden der Attributgruppe "atg.prozessInfo" an den DaV |
void |
sendeStartStoppAntwort(long absenderId,
java.lang.String absenderZeichen,
java.lang.String id,
SkriptVewEnums.E_ZUSTAND zustand,
SkriptVewEnums.E_FEHLER_STARTSTOPPBLOCK fehler)
Methode sendet die Attributgruppe "atg.startStoppAntwort" an den Prozess mit der Id absenderId. |
void |
sendeStartStoppInfo()
Methode zum Senden der Attributgruppe "atg.startStoppInfo" an den DaV Besteht zum Zeitpunkt des Sendens die Verbindung zum DaV noch nicht (z.B. nach einem Systemstart) so startet die Methode einen Listener, der auf die Verbindung wartet und dann erst die Attributgruppe versendet. |
void |
sendMessage(de.bsvrz.sys.funclib.operatingMessage.MessageType type,
java.lang.String messageTypeAddOn,
de.bsvrz.sys.funclib.operatingMessage.MessageGrade grade,
java.lang.String message)
Methode erzeugt eine Betriebsmeldung und sendet diese an den Datenverteiler. |
void |
trenneDaV()
Method trennt die Verbindung zum DaV |
void |
update(de.bsvrz.dav.daf.main.ResultData[] arg0)
Umpdate Methode zum Empfang der Daten des DaV |
private de.bsvrz.dav.daf.main.ClientDavInterface |
verbindeMitDaV()
Methode stellt die Verbindung zum DaV her. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private static final long serialVersionUID
private static final de.bsvrz.sys.funclib.debug.Debug logger
private static java.lang.StringBuilder _applicationLabel
private static java.lang.String _applicationName
private final boolean _debugAnmelde
private final boolean _debugFertigMeldung
private java.util.HashMap<java.lang.Long,java.lang.Integer> m_listeDavApplikationen
private java.util.HashMap<java.lang.Long,java.lang.String> m_zuordnungIdZuInkarnationen
static boolean m_verbunden
public boolean m_angemeldet
public de.bsvrz.dav.daf.main.ClientDavInterface m_connection
public de.bsvrz.dav.daf.main.ClientDavInterface m_connectionFuerImmer
private java.lang.String m_pidRechner
private boolean m_sendeProzessInfo
private boolean m_sendeStartStoppInfo
private java.util.List<java.lang.Long> m_warteApplikationsFertigmeldung
private java.util.Vector<DaVKommunikation.AngemeldeterSender> m_angemeldeteSender
private java.util.Vector<DaVKommunikation.AngemeldeterEmpfaenger> m_angemeldeteEmpfaenger
Constructor Detail |
---|
private DaVKommunikation()
Method Detail |
---|
public static DaVKommunikation getInstanz()
public boolean baueVerbindungDaVAuf()
private de.bsvrz.dav.daf.main.ClientDavInterface verbindeMitDaV()
private java.lang.String exceptionMeldungBestimmen(java.lang.Exception exception)
exception
- zu verarbeitende Exception.
public void trenneDaV()
public void anmeldeDaV()
private void anmeldeLeseRechner()
public java.lang.String bestimmePidRechnerByHost(java.lang.String host)
host
- Rechnername
public java.lang.String bestimmePidRechnerByIp(java.lang.String ip)
ip
- TCP/IP Adresse
private java.lang.String bestimmePidRechner(int art, java.lang.String value)
art
- 0 - Bestimmen der Pid auf Basis des Rechnernamens
1 - Bestimmen der Pid auf Basis der TCP/IP Adressevalue
- Rechnername oder IP-Adresse
public boolean isPidRechnerGueltig(java.lang.String pidRechner)
pidRechner
- zu prüfende Pid
private java.lang.String bestimmeIpRechner(java.lang.String pidRechner)
pidRechner
- Pid des Rechners
public de.bsvrz.dav.daf.main.DataDescription anmeldeSendeDaV(java.lang.String objPid, java.lang.String atgPid, java.lang.String aspPid, de.bsvrz.dav.daf.main.SenderRole role)
objPid
- Pid des ObjektsatgPid
- Pid der AttributgruppeaspPid
- Pid des Aspektspublic de.bsvrz.dav.daf.main.DataDescription anmeldeSendeDaV(long objId, java.lang.String atgPid, java.lang.String aspPid, de.bsvrz.dav.daf.main.SenderRole role)
objId
- Id des ObjektsatgPid
- Pid der AttributgruppeaspPid
- Pid des Aspektspublic void abmeldeSendeDaV(long objId, java.lang.String atgPid, java.lang.String aspPid)
objId
- Id des ObjektsatgPid
- Attributgruppe die abgemeldet werden sollaspPid
- Apekt der abgemeldet werden sollpublic void abmeldeLeseDaV(long objId, java.lang.String atgPid, java.lang.String aspPid)
objId
- Id des ObjektsatgPid
- Attributgruppe die abgemeldet werden sollaspPid
- Apekt der abgemeldet werden sollprivate void anmeldeLeseDaV(long objId, java.lang.String atgPid, java.lang.String aspPid, de.bsvrz.dav.daf.main.ReceiverRole role)
objId
- Id des ObjektsatgPid
- Attributgruppe die angemeldet werden sollaspPid
- Apekt der angemeldet werden sollrole
- Rolle des Empfängers (siehe stauma.dav.clientside.ReceiveOptions)private void anmeldeLeseDaV(java.lang.String objPid, java.lang.String atgPid, java.lang.String aspPid, de.bsvrz.dav.daf.main.ReceiverRole role)
objPid
- Pid des ObjektsatgPid
- Attributgruppe die angemeldet werden sollaspPid
- Apekt der angemeldet werden sollrole
- Rolle des Empfängers (siehe stauma.dav.clientside.ReceiveOptions)public boolean istVerbunden()
public void update(de.bsvrz.dav.daf.main.ResultData[] arg0)
update
in interface de.bsvrz.dav.daf.main.ClientReceiverInterface
public void sendeBetriebsmeldung(java.lang.String text)
text
- Text der als Betriebsmeldung gesendet werden sollpublic void sendMessage(de.bsvrz.sys.funclib.operatingMessage.MessageType type, java.lang.String messageTypeAddOn, de.bsvrz.sys.funclib.operatingMessage.MessageGrade grade, java.lang.String message)
type
- der MeldungsTypmessageTypeAddOn
- der MeldungsTypZusatzgrade
- die MeldungsKlassemessage
- Text der Meldungpublic void sendeStartStoppAntwort(long absenderId, java.lang.String absenderZeichen, java.lang.String id, SkriptVewEnums.E_ZUSTAND zustand, SkriptVewEnums.E_FEHLER_STARTSTOPPBLOCK fehler)
absenderId
- Id des AbsenderprozessesabsenderZeichen
- Zeichen des Absendeprozessesid
- des Prozesses, bzw. des StartStopp-Blocks dessen Status übertragen wirdzustand
- Zustand des Prozesses bzw. des StartStopp Blocks (de.bsvrz.sys.startstopp.skriptvew.SkriptVewEnums.Zustand)fehler
- Fehlerkennung (de.bsvrz.sys.startstopp.skriptvew.SkriptVewEnums.E_FEHLER_STARTSTOPPBLOCK)public void sendeProzessInfo()
private de.bsvrz.dav.daf.main.Data erstelleProzessInfo()
public void sendeStartStoppInfo()
private void _sendeStartStoppinfo()
private de.bsvrz.dav.daf.main.Data erstelleStartStoppInfo()
public void dataRequest(de.bsvrz.dav.daf.main.config.SystemObject arg0, de.bsvrz.dav.daf.main.DataDescription arg1, byte arg2)
dataRequest
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
public boolean isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject arg0, de.bsvrz.dav.daf.main.DataDescription arg1)
isRequestSupported
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
private boolean pruefeUsv(java.lang.String pidUsv)
pidUsv
- Pid der USV
private java.util.List<java.lang.String> bestimmeObjekte(java.lang.String objPid)
objPid
- Pid der Objekttypen
public boolean isInkarnationAmDaVAngemeldet(java.lang.String inkarnation)
inkarnation
- Inkarnationsname der zu prüfenden Applikation
public de.bsvrz.dav.daf.main.ClientDavInterface getConnection()
null
, wenn keine besteht.public de.bsvrz.dav.daf.main.ClientDavInterface getConnectionFuerImmer()
public java.util.Vector<DaVKommunikation.AngemeldeterSender> getAngemeldeteSender()
public java.util.Vector<DaVKommunikation.AngemeldeterEmpfaenger> getAngemeldeteEmpfaenger()
public void allesAbmelden()
public java.lang.String getPidRechner()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |