public class T_A_HighLevelCommunication extends Object implements T_A_HighLevelCommunicationInterface, HighLevelCommunicationCallbackInterface
Modifier and Type | Field and Description |
---|---|
private long |
_applicationId
Der Applikation Id
|
private HighLevelApplicationManager |
_applicationManager |
private String |
_applicationName
Der Name der Applikation
|
private String |
_applicationTypePid
Die Pid des Applikationstyps
|
private AuthentificationComponent |
_authentificationComponent
Die Authentifizierungskomponente
|
private boolean |
_closed |
private Object |
_closedLock |
private long |
_configurationId
Der Konfiguration Id
|
private String |
_configurationPid
Die Pid der Konfiguration
|
private long |
_connectionCreatedTime |
private static Debug |
_debug |
private LowLevelCommunicationInterface |
_lowLevelCommunication
Die erste Ebene der Kommunikation
|
private LowLevelConnectionsManagerInterface |
_lowLevelConnectionsManager |
private ServerConnectionProperties |
_properties
Die Eigenschaften diese Verbindung
|
private long |
_remoteUserId
Die Id des Benutzers
|
private Map<BaseSubscriptionInfo,List<ApplicationDataTelegram>> |
_stalledTelegramListMap
Map in der eine je Datenidentifikation eine Liste von empfangenen Telegrammen, die zu einem Datensatz gehören zwischengespeichert werden können
|
private Object |
_sync
Objekt zur internen Synchronization
|
private List<DataTelegram> |
_syncSystemTelegramList
Temporäre Liste der Systemtelegramme für interne Synchronisationszwecke.
|
private int[] |
_versions
Die unterstützten Versionen des Datenverteilers
|
private boolean |
_waitForConfiguration
Die Information ob auf die Konfiguration gewartet werden muss.
|
Constructor and Description |
---|
T_A_HighLevelCommunication(ServerConnectionProperties properties,
HighLevelApplicationManager applicationManager,
LowLevelConnectionsManagerInterface lowLevelConnectionsManager,
boolean waitForConfiguration)
Erzeugt ein neues Objekt mit den gegebenen Parametern.
|
Modifier and Type | Method and Description |
---|---|
void |
continueAuthentification()
Diese Methode wird von der Verbindungsverwaltung aufgerufen, sobald die Konfiguration vorhanden ist, um zu signalisieren, dass eine blockierte
Authentifizierung weiter bearbeitet werden kann: Steht eine Authentifizierungsschlüsselanfrage an, während die Konfiguration noch nicht vorhanden ist, wird
die Antwort blockiert bis die Konfiguration bereit ist.
|
List<ApplicationDataTelegram> |
createStalledTelegramList(BaseSubscriptionInfo info,
int maxCount)
Erzeugt eine Liste für verzögerte Telegramme für eine Datenidentifikation und speichert sie in einer Map.
|
List<ApplicationDataTelegram> |
deleteStalledTelegramList(BaseSubscriptionInfo info)
Liefert eine vorher erzeugte Liste für verzögerte Telegramme für eine Datenidentifikation und entfernt sie aus der Map.
|
void |
disconnected(boolean error,
String message)
Wird von der unteren Kommunikationsschicht in Fehlersituationen zum Abbruch der Kommunikationsverbindung aufgerufen.
|
String |
getApplicationName()
Gibt den Namen der Applikation zurück.
|
String |
getApplicationTypePid()
Gibt den Typ der Applikation zurück.
|
long |
getConfigurationId()
Gibt die Id der Konfiguration zurück.
|
long |
getConnectionCreatedTime()
Zeitpunkt, an dem das Objekt erstellt wurde und somit eine Verbindung zum DaV bestand.
|
long |
getId()
Diese Methode wird von der Verbindungsverwaltung aufgerufen, um die ID der verbundenen Applikation zu erhalten.
|
private int |
getPrefferedVersion(int[] versions)
Gibt die Version zurück, die von dieser Verbindung unterstützt wird.
|
long |
getRemoteUserId()
Gibt die ID des verbundenen Benutzers zurück.
|
String |
getSendBufferState()
Liefert einen beschreibenden Text mit dem Zustand des Sendepuffers aus der LowLevelCommunication.
|
List<ApplicationDataTelegram> |
getStalledTelegramList(BaseSubscriptionInfo info)
Liefert eine vorher erzeugte Liste für verzögerte Telegramme für eine Datenidentifikation.
|
long |
getTelegramTime(long maxWaitingTime)
Diese Methode wird von der Verbindungsverwaltung aufgerufen.
|
boolean |
isConfiguration()
Gibt zurück, ob es sich um die Konfiguration handelt.
|
void |
sendData(ApplicationDataTelegram telegram) |
void |
sendData(ApplicationDataTelegram[] telegrams) |
void |
sendData(ApplicationDataTelegram telegram,
boolean toCentralDistributor)
Versendet ein Daten-Telegramm übr diese Verbindung
|
void |
terminate(boolean error,
String message)
Terminiert die Kommunikationsverbindung.
|
void |
terminate(boolean error,
String message,
DataTelegram terminationTelegram) |
String |
toString() |
void |
triggerSender(BaseSubscriptionInfo data,
byte state)
Diese Methode wird von der Verbindungsverwaltung aufgerufen, um eine Sendesteuerung an die Applikation weiterzuleiten.
|
void |
update(DataTelegram telegram)
Wird von der unteren Kommunikationsschicht nach Empfang eines Telegramms aufgerufen.
|
void |
updateConfigData(SendDataObject receivedData)
Wenn ein neues Konfigurationstelegramm angekommen ist, wird es an die Verwaltung weitergeleitet.
|
private static final Debug _debug
private LowLevelCommunicationInterface _lowLevelCommunication
private ServerConnectionProperties _properties
private int[] _versions
private long _applicationId
private long _remoteUserId
private long _configurationId
private String _applicationName
private String _applicationTypePid
private String _configurationPid
private AuthentificationComponent _authentificationComponent
private List<DataTelegram> _syncSystemTelegramList
private boolean _waitForConfiguration
private Object _sync
private boolean _closed
private Object _closedLock
private final long _connectionCreatedTime
private Map<BaseSubscriptionInfo,List<ApplicationDataTelegram>> _stalledTelegramListMap
private final HighLevelApplicationManager _applicationManager
private final LowLevelConnectionsManagerInterface _lowLevelConnectionsManager
public T_A_HighLevelCommunication(ServerConnectionProperties properties, HighLevelApplicationManager applicationManager, LowLevelConnectionsManagerInterface lowLevelConnectionsManager, boolean waitForConfiguration)
properties
- stellt die Parameter einer Verbindung zwischen zwei ServernlowLevelConnectionsManager
- waitForConfiguration
- true: ,false:public final long getTelegramTime(long maxWaitingTime) throws CommunicationError
ServerHighLevelCommunication
TelegramTimeRequest
wird erzeugt und zur Applikation gesendet. Danach
wird auf die Antwort TelegramTimeAnswer
gewartet. Wenn die Antwort nicht innerhalb der angegebenen
maximalen Wartezeit angekommen ist, wird eine Ausnahme
erzeugt.getTelegramTime
in interface ServerHighLevelCommunication
maxWaitingTime
- Maximale Zeit, die auf eine Antwort gewartet wird.-1
, wenn nicht innnerhalb der maximalen Wartezeit eine Antwort empfangen wurde.CommunicationError
- Wenn bei der initialen Kommunikation mit dem Datenverteiler Fehler aufgetreten sind.public final void sendData(ApplicationDataTelegram telegram, boolean toCentralDistributor)
CommunicationInterface
sendData
in interface CommunicationInterface
telegram
- TelegrammtoCentralDistributor
- true: In Richtung des Zentraldatenverteilers, beim Sender-Senke-Datenfluss.
false: Aus Richtung des Zentraldatenverteilers, beim Quelle-Empfänger-Datenfluss.public final void sendData(ApplicationDataTelegram telegram)
public final void sendData(ApplicationDataTelegram[] telegrams)
public final void terminate(boolean error, String message)
ServerHighLevelCommunication
terminate
in interface ServerHighLevelCommunication
error
- Ist true
, wenn die Verbindung im Fehlerfall abgebrochen werden soll, ohne die noch gepufferten Telegramme zu versenden;
false
, wenn versucht werden soll alle gepufferten Telegramme zu versenden.message
- Fehlermeldung, die die Fehlersituation näher beschreibt.public long getConnectionCreatedTime()
public String getSendBufferState()
LowLevelCommunicationInterface.getSendBufferState()
public final void terminate(boolean error, String message, DataTelegram terminationTelegram)
public void disconnected(boolean error, String message)
de.bsvrz.dav.daf.communication.lowLevel.HighLevelCommunicationCallbackInterface
disconnected
in interface HighLevelCommunicationCallbackInterface
error
- true
signalisiert eine Fehlersituation der unteren Kommunikationsschicht.message
- Fehlermeldung, die die Fehlersituation näher beschreibt.public void updateConfigData(SendDataObject receivedData)
de.bsvrz.dav.daf.communication.lowLevel.HighLevelCommunicationCallbackInterface
updateConfigData
in interface HighLevelCommunicationCallbackInterface
receivedData
- das Konfigurationstelegrammpublic final void triggerSender(BaseSubscriptionInfo data, byte state)
ApplicationCommunicationInterface
RequestSenderDataTelegram
-Array gebildet und über die Telegrammverwaltung an die Applikation gesendet.triggerSender
in interface ApplicationCommunicationInterface
data
- Anmeldeinformationenstate
- BenachrichtigungscodeRequestSenderDataTelegram
public final long getId()
ServerHighLevelCommunication
getId
in interface ServerHighLevelCommunication
getId
in interface CommunicationInterface
public final long getRemoteUserId()
ServerHighLevelCommunication
getRemoteUserId
in interface ServerHighLevelCommunication
getRemoteUserId
in interface CommunicationInterface
public final long getConfigurationId()
T_A_HighLevelCommunicationInterface
getConfigurationId
in interface T_A_HighLevelCommunicationInterface
public final String getApplicationTypePid()
T_A_HighLevelCommunicationInterface
getApplicationTypePid
in interface T_A_HighLevelCommunicationInterface
public final String getApplicationName()
T_A_HighLevelCommunicationInterface
getApplicationName
in interface T_A_HighLevelCommunicationInterface
public final boolean isConfiguration()
T_A_HighLevelCommunicationInterface
isConfiguration
in interface T_A_HighLevelCommunicationInterface
true
, wenn es sich um die Konfiguration handelt, sonst false
public final void continueAuthentification()
ServerHighLevelCommunication
continueAuthentification
in interface ServerHighLevelCommunication
private int getPrefferedVersion(int[] versions)
versions
- Versionen, die unterstützt werden sollen. Wird null
übergeben, so wird -1 zurückgegeben.public final void update(DataTelegram telegram)
de.bsvrz.dav.daf.communication.lowLevel.HighLevelCommunicationCallbackInterface
update
in interface HighLevelCommunicationCallbackInterface
telegram
- Das empfangene Telegrammpublic List<ApplicationDataTelegram> createStalledTelegramList(BaseSubscriptionInfo info, int maxCount)
info
- Datenidentifikation der verzögerten TelegrammemaxCount
- Maximale Anzahl der verzögerten TelegrammegetStalledTelegramList(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo)
,
deleteStalledTelegramList(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo)
public List<ApplicationDataTelegram> getStalledTelegramList(BaseSubscriptionInfo info)
info
- Datenidentifikation der verzögerten TelegrammecreateStalledTelegramList(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo,int)
,
deleteStalledTelegramList(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo)
public List<ApplicationDataTelegram> deleteStalledTelegramList(BaseSubscriptionInfo info)
info
- Datenidentifikation der verzögerten TelegrammecreateStalledTelegramList(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo,int)
,
getStalledTelegramList(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo)