|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.dav.dav.main.ConnectionsManager
public class ConnectionsManager
Diese Komponente startet alle notwendigen Aktionen, um eine bestimmte Aufgabe zu erledigen durch den Aufruf einer ihrer Methoden. Die Aktionen werden natürlich nur durchgeführt, wenn der Initiator auch eine Berechtigung dafür hat. Die Berechtigung entnimmt man der Initiatorrolle. Wenn die Rolle nicht lokal vorhanden ist, wird sie aus der Konfiguration ausgelesen.
Nested Class Summary | |
---|---|
private static class |
ConnectionsManager.ApplicationConnection
|
(package private) class |
ConnectionsManager.ApplicationConnectionsSubscriber
Diese Subklasse startet einen Thread, der eine Application bei einem Datenverteiler anmeldet. |
class |
ConnectionsManager.ApplicationStatusUpdater
Dieser Thread verschickt den Status(angemeldete Appliktionen, Telegrammlaufzeiten, durch Applikationen angemeldete Datenidentifikationen) aller angemeldeten Applikationen. |
private class |
ConnectionsManager.SourceApplicationUpdater
|
(package private) class |
ConnectionsManager.TransmitterConnectionsMonitor
|
(package private) class |
ConnectionsManager.TransmitterConnectionsSubscriber
Diese Subklasse startet eine Thread, der eine DAV bei einem DAV anmeldet. |
Field Summary | |
---|---|
private List<T_A_HighLevelCommunication> |
_applicationConnections
Liste der Applikationsverbindungen |
private ConnectionsManager.ApplicationConnectionsSubscriber |
_applicationConnectionsSubscriber
Interne Thread zur Kommunikation |
private ServerConnectionInterface |
_applicationsServerConnection
Die Serverkommunikationskomponente der Datenverteiler, die Applikationsverbindungen akzeptiert. |
private ConnectionsManager.ApplicationStatusUpdater |
_applicationStatusUpdater
Dieser Thread verschickt die Statusinformationen über angemeldete Applikationen. |
private AuthentificationComponent |
_authentificationComponent
Der Authentifikationskomponente |
private ClientDavParameters |
_clientDavParameters
Die Startparameters dieses Datenverteilers als Applikation |
private boolean |
_closing
Interne Variable (Closing state) |
private boolean |
_configurationAvaillable
Information ob die Konfigurationsverbindung erfolgreich ist. |
private long |
_configurationId
Die ID des Konfigurationsverantwortlichen der Konfiguration. |
private ConnectionsManager.TransmitterConnectionsMonitor |
_connectionsMonitor
Überwacht die Nachbarnverbindungen und leitet Ersatzverbindungen wenn nötig |
private static Debug |
_debug
|
private ArrayList |
_pendingSubscriptionToRedirect
Liste der auf eine positive Quitung wartenden Anmeldungen, die über einen neuen weg umgeleitet werden müssen. |
private String |
_pidAngemeldeteApplikationen
ATG, die benötigt wird um einen Datensatz zu verschicken, der alle angemeldeten Applikationen enthält. |
private String |
_pidAngemeldeteDatenidentifikationen
ATG, die benötigt wird um einen Datensatz zu verschicken, der die angemeldeten Daten aller angemeldeten Applikationen enthält. |
private String |
_pidTelegrammLaufzeiten
ATG, die benötigt wird um einen Datensatz zu verschicken, der die Telegrammlaufzeiten aller angemeldeten Applikationen enthält. |
private ServerDavParameters |
_serverDavParameters
Die Startparameters dieses Datenverteilers |
private TransmitterConnectionInfo[] |
_transmitterConnectionInfos
Die Netztopologie dieses Datenverteilers |
private List<T_T_HighLevelCommunication> |
_transmitterConnections
Liste der Datenverteilerverbindungen |
private ConnectionsManager.TransmitterConnectionsSubscriber |
_transmitterConnectionsSubscriber
Interne Thread zur Kommunikation |
private long |
_transmitterId
Die Id des Datenverteilers |
private ServerConnectionInterface |
_transmittersServerConnection
Die Serverkommunikationskomponente der Datenverteiler, die Datenverteilersverbindungen akzeptiert. |
(package private) AuthentificationManager |
authentificationManager
Der Authentifikationsmanager |
private BestWayManager |
bestWayManager
Der Bestwege-Manager |
(package private) CacheManager |
cacheManager
Der Cache Manager |
(package private) DataModel |
dataModel
Das DataModel zur Konfigurationsabfrage |
private static short |
DEFAULT_WEIGHT
|
private ListsManager |
listsManager
Der Objekte-Attributesgruppen-Aspekte-Listen-Manager |
private Vector |
missedConnectionInfos
Die Liste der nicht etablierten Verbindungen |
(package private) ClientDavConnection |
selfClientDavConnection
Die eigene DAF-Verbindung |
private SubscriptionsManager |
subscriptionsManager
Der Anmeldemanager |
Constructor Summary | |
---|---|
ConnectionsManager()
Dieser Konstruktor wird für Tests benötigt. |
|
ConnectionsManager(ServerDavParameters serverDavParameters)
Erzeugt eine neue Verbindungsverwaltung für den Datenverteiler. |
Method Summary | |
---|---|
private void |
cleanPendingSubscriptionToRedirect(InAndOutSubscription subscription)
Aktualisiert die Liste der auf eine positive Quitung wartenden Anmeldungen, die über einen neuen weg umgeleitet werden müssen. |
private void |
cleanPendingSubscriptionToRedirect(InAndOutSubscription subscription,
OutSubscriptionsHelper subscriptionHelper)
Aktualisiert die Liste mit austehenden Anmeldungen TBD: noch nicht gut beschrieben |
void |
close(boolean error,
String message)
Diese Methode wird von der Datenverteilerapplikation aufgerufen wenn ein Datenverteiler heruntergefahren wird. |
private void |
connectToAlternativeTransmitters(TransmitterConnectionInfo transmitterConnectionInfo)
Startet den Ersatzverbindungsaufbau zwischen zwei nicht direkt benachbarten Datenverteilern. |
private boolean |
connectToMainTransmitter(TransmitterConnectionInfo transmitterConnectionInfo)
Startet den Verbindungsaufbau zwischen zwei direkt benachbarten Datenverteilern. |
private void |
connectToNeighbours()
Verbindet mit den Nachbarndatenverteiler |
private boolean |
connectToTransmitter(TransmitterInfo t_info,
short weight,
long time,
String userName)
Startet den Verbindungsaufbau zwischen zwei Datenverteilern. |
private void |
connectToTransmitter(TransmitterInfo t_info,
short weight,
String userName,
String password)
Etabliert Verbindung zwischen zwei Datenverteilern. |
(package private) T_A_HighLevelCommunication |
getApplicationConnection(long applicationId)
Diese Methode wird von der Protokollsteuerung DaV-DAF, der Anmeldungsverwaltung und von dieser Komponente selber aufgerufen. |
private List |
getApplicationConnections(long userId)
Erstellt eine Liste der DAV-DAF-Verbindungen für den entsprechenden Benutzer. |
long |
getApplicationId(String applicationTypePid,
String applicationName)
Gibt die ID der Applikation zurück |
long |
getConfigurationId(String configurationPid)
Gibt die ID der Konfiguration mit der gegebenen Pid zurück |
private TransmitterConnectionInfo[] |
getInvolvedTransmitters(TransmitterInfo t_info)
Erstellt ein Array, das die Informationen über die benachbarten Datenverteiler des übergebenen Datenverteilers enthält. |
long |
getLocaleModeConfigurationId()
Gibt die configurationId des Lokalen Modus zurück. |
String |
getLocaleModeConfigurationPid()
Gibt die configurationPid des Lokalen Modus zurück. |
String |
getPasswordForAuthentification(long connectedTransmitterId)
Bestimmt das Benutzerpasswort das zur Authentifizierung beim angegebenen Datenverteiler benutzt werden soll. |
private TransmitterConnectionInfo |
getRemoteTransmitterConnectionInfo(long connectedTransmitterId)
Bestimmt die Verbindungsinformationen für eine Verbindung vom angegebenen Datenverteiler zu diesem Datenverteiler. |
ServerDavParameters |
getServerDavParameters()
Bestimmt die Einstellungen des Datenverteilers, die über Aufrufargumente verändert werden können. |
T_T_HighLevelCommunication |
getTransmitterConnection(long communicationTransmitterId)
Diese Methode ermittelt eine in der Verbindungsverwaltung registrierte Datenverteilerverbindung zu einem bestimmten anderen Datenverteiler. Diese Methode wird von der Protokollsteuerung DaV-DaV, der Anmeldungsverwaltung und von dieser Komponente selber aufgerufen. |
private TransmitterConnectionInfo |
getTransmitterConnectionInfo(long connectedTransmitterId)
Bestimmt die Verbindungsinformationen für eine Verbindung von diesem Datenverteiler zum angegebenen Datenverteiler. |
private List |
getTransmitterConnections(long userId)
Erstellt eine Liste der DAV-DAV-Verbindungen für den entsperchenden Benutzer. |
long |
getTransmitterId()
Bestimmt die Objekt-ID des lokalen Datenverteilers. |
String |
getUserNameForAuthentification(long connectedTransmitterId)
Bestimmt den Benutzername der zur Authentifizierung beim angegebenen Datenverteiler benutzt werden soll. |
short |
getWeight(long connectedTransmitterId)
Diese Methode wird von der Protokollsteuerung aufgerufen, um einer Verbindung ein Gewicht zuzuweisen. |
void |
handleApplicationReceiveSubscription(T_A_HighLevelCommunication connection,
ReceiveSubscriptionTelegram subscription)
Leitet die Anmeldungen an den beteiligten Datenverteiler weiter. |
void |
handleApplicationReceiveUnsubscription(T_A_HighLevelCommunication connection,
ReceiveUnsubscriptionTelegram unsubscription)
Meldet die Daten ab und leitet die Abmeldungen, wenn nötig, an die beteiligten Datenverteiler weiter. |
void |
handleApplicationSendSubscription(T_A_HighLevelCommunication connection,
SendSubscriptionTelegram subscription)
Leitet die Anmeldungen an den beteiligten Datenverteiler weiter. |
void |
handleApplicationSendUnsubscription(T_A_HighLevelCommunication connection,
SendUnsubscriptionTelegram unsubscription)
Meldet die Daten ab und leitet die Abmeldungen, wenn nötig, an den beteiligten Datenverteiler. |
private void |
handleInvalidSubscription(InAndOutSubscription subscription,
long mainTransmitterId)
Hilfsmehode zu private final void handleNegativeReceip(...) Behandelt eine mehr als einmal positiv quittierte Anmeldung |
void |
handleListsDeliveryUnsubscription(T_T_HighLevelCommunicationInterface connection,
TransmitterListsDeliveryUnsubscription transmitterListsDeliveryUnsubscription)
Diese Methode wird von der Protokollsteuerung DaV-DaV aufgerufen, wenn eine Kündigung einer Anmeldung einer Zuliefererinformation eines Datenverteilers angekommen ist. |
void |
handleListsSubscription(T_T_HighLevelCommunicationInterface connection,
TransmitterListsSubscription transmitterListsSubscription)
Diese Methode wird von der Protokollsteuerung DaV-DaV aufgerufen, wenn eine Anmeldung einer Zuliefererinformation eines Datenverteilers angekommen ist. |
void |
handleListsUnsubscription(T_T_HighLevelCommunicationInterface connection,
TransmitterListsUnsubscription transmitterListsUnsubscription)
Diese Methode wird von der Protokollsteuerung DaV-DaV aufgerufen, wenn eine Abmeldung einer Zuliefererinformation eines Datenverteilers angekommen ist. |
void |
handleListsUpdate(T_T_HighLevelCommunicationInterface connection,
TransmitterListsUpdate transmitterListsUpdate)
Diese Methode wird von der Protokollsteuerung DaV-DaV aufgerufen, wenn eine Aktualisierung der Zuliefererinformationen von einen Datenverteiler angekommen ist. |
private void |
handleNegativeReceip(InAndOutSubscription subscription)
Hilfsmethode zu final void handleTransmitterSubscriptionReceip(InAndOutSubscription subscription, long targetId, BaseSubscriptionInfo info, long
mainTransmitterId, long transmitterIds[],byte subscriptionState,byte receip) . |
private void |
handlePositiveReceip(InAndOutSubscription subscription,
byte receip,
long mainTransmitterId)
Hilfsmethode zur Behandelung einer positive Quittung einer Anmeldung. |
void |
handleTransmitterSubscription(T_T_HighLevelCommunicationInterface connection,
TransmitterDataSubscription subscription)
Leitet die Anmeldungen an den beteiligten Datenverteiler weiter. |
(package private) void |
handleTransmitterSubscriptionReceip(InAndOutSubscription subscription,
long targetId,
BaseSubscriptionInfo info,
long mainTransmitterId,
long[] transmitterIds,
byte subscriptionState,
byte receip)
Hilfsmethode zu final synchronized void handleTransmitterSubscriptionReceip(T_T_HighLevelCommunication connection, TransmitterDataSubscriptionReceipt
receipTelegram) |
void |
handleTransmitterSubscriptionReceip(T_T_HighLevelCommunicationInterface connection,
TransmitterDataSubscriptionReceipt receiptTelegram)
Diese Methode wird von der Protokollsteuerung DaV-DaV aufgerufen, um eine anstehende Anmeldung zu quittieren. |
void |
handleTransmitterUnsubscription(T_T_HighLevelCommunicationInterface connection,
TransmitterDataUnsubscription unsubscription)
Diese Methode wird von der Protokollsteuerung DaV-DaV aufgerufen, um ein Abmeldungstelegramm eines Datenverteilers zu bearbeiten.Der Eintrag mit den Abmeldungsinformationen wird aus der Verwaltungstabelle entfernt. |
(package private) void |
handleUserRightsChanged(long userId)
Aktualisiert die Anmeldungen eines Datenverteiler oder einer Applikation bezüglich der neuen Rechte. |
long |
isValidUser(String userName,
byte[] encriptedPassword,
String authentificationText,
AuthentificationProcess authentificationProcess,
String typePid)
Fragt die Konfiguration, ob der übergegebene User mit dem Passwort ein berechtigter Benutzer ist oder nicht. |
private void |
makeOutgoingRequests(InAndOutSubscription request)
Erzeugt die notwendigen Informationen zu den Anmeldungen, die verschickt werden. |
void |
printSubscriptions()
Diese Methode ruft subscriptionsManager.printSubscriptions auf, welche die Anmeldeinformationen in den OutputSream schreibt. |
private SystemObject |
removeApplicationConnection(long applicationId)
Entfernt Verbindung zwischen DAV und DAF |
private void |
removeTransmitterConnection(long communicationTransmitterId)
Entfernt Verbindung zwischen zwei DAV |
void |
setLocalConfigurationAvaillable()
Setzt dass die Konfigurationsverbindung erfolgreich hergestellt ist |
void |
setLocaleModeParameter(String configurationPid,
long configurationId)
Setzt den Datenverteilersbetriebsmodus auf den Lokalen Modus. |
void |
unsubscribeConnection(T_A_HighLevelCommunicationInterface connection)
Entfernt der gegebene Applikationsverbindung aus der Verbindungsverwaltung. |
void |
unsubscribeConnection(T_T_HighLevelCommunicationInterface connection)
Diese Methode wird von der Protokollsteuerung DaV-DaV aufgerufen, wenn ein Datenverteiler terminiert. |
void |
updateDestinationRoute(long _transmitterId,
RoutingConnectionInterface oldConnection,
RoutingConnectionInterface newConnection)
Wird aufgerufen, wenn die Kommunikation zu einem anderen Datenverteiler über eine andere Verbindung erfolgen sollte. |
(package private) boolean |
updatePendingSubscription(BaseSubscriptionInfo info,
long connectedTransmitterId,
long dataIndex)
Diese Methode wird von der Anmeldungsverwaltung aufgerufen, wenn ein neuer Datensatz angekommen ist. |
private void |
workInvolvedSubscription(InAndOutSubscription involvedSubscription,
OutSubscriptionsHelper subscriptionHelper)
Behandelt eine Anmeldung nach einer Abmeldeaktion... |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private static final Debug _debug
private static final short DEFAULT_WEIGHT
private final ServerDavParameters _serverDavParameters
private final ClientDavParameters _clientDavParameters
private final ServerConnectionInterface _applicationsServerConnection
private ServerConnectionInterface _transmittersServerConnection
private final AuthentificationComponent _authentificationComponent
private ConnectionsManager.TransmitterConnectionsSubscriber _transmitterConnectionsSubscriber
private ConnectionsManager.ApplicationConnectionsSubscriber _applicationConnectionsSubscriber
private List<T_T_HighLevelCommunication> _transmitterConnections
private final List<T_A_HighLevelCommunication> _applicationConnections
private ConnectionsManager.ApplicationStatusUpdater _applicationStatusUpdater
null
, so wurde der Thread nicht initialisiert(die genannten ATG´s fehlen) und der Mechanismus steht nicht zur Verfügung.
private ArrayList _pendingSubscriptionToRedirect
private boolean _configurationAvaillable
private final long _transmitterId
private TransmitterConnectionInfo[] _transmitterConnectionInfos
private Vector missedConnectionInfos
private ConnectionsManager.TransmitterConnectionsMonitor _connectionsMonitor
private volatile boolean _closing
ClientDavConnection selfClientDavConnection
DataModel dataModel
private final SubscriptionsManager subscriptionsManager
private final ListsManager listsManager
private final BestWayManager bestWayManager
final CacheManager cacheManager
final AuthentificationManager authentificationManager
private long _configurationId
private final String _pidAngemeldeteApplikationen
private final String _pidAngemeldeteDatenidentifikationen
private final String _pidTelegrammLaufzeiten
Constructor Detail |
---|
public ConnectionsManager()
public ConnectionsManager(ServerDavParameters serverDavParameters) throws CommunicationError, MissingParameterException, InconsistentLoginException, ConnectionException
serverDavParameters
- Die Parameter sind u. a. die Adressen und Subadressen der Kommunikationskanäle
CommunicationError
- wenn bei der initialen Kommunikation mit dem Datenverteiler Fehler aufgetreten sind
MissingParameterException
- wenn notwendige Verbindungsparameter nicht spezifiziert wurden
InconsistentLoginException
- bei einem fehlgeschlagenen Authentifizierungsversuch
ConnectionException
- wenn eine Verbindung nicht aufgebaut werden konnteMethod Detail |
---|
public final long getTransmitterId()
ConnectionsManagerInterface
getTransmitterId
in interface ConnectionsManagerInterface
private void connectToNeighbours()
private boolean connectToMainTransmitter(TransmitterConnectionInfo transmitterConnectionInfo)
transmitterConnectionInfo
- Enthält Informationen zu der Verbindungart zwischen zwei Datenverteilern.
connectToTransmitter(de.bsvrz.dav.daf.main.impl.config.telegrams.TransmitterInfo,short,long,String)
private void connectToAlternativeTransmitters(TransmitterConnectionInfo transmitterConnectionInfo)
transmitterConnectionInfo
- Enthält Informationen zu der Verbindungart zwischen zwei Datenverteilern.connectToTransmitter(de.bsvrz.dav.daf.main.impl.config.telegrams.TransmitterInfo,short,long,String)
private boolean connectToTransmitter(TransmitterInfo t_info, short weight, long time, String userName)
t_info
- Information zum Datenverteilerweight
- Die Information wird von der Wegverwaltung benutzt, wenn eine Verbindung bewertet wird.time
- Zeitspanne in der versucht werden soll eine Verbindung aufzubauen, in Millisekunden. Maximale Wartezeit eine Sekunde.userName
- Benutzername mit dem die Authentifizierung durchgeführt werden soll.
connectToTransmitter(de.bsvrz.dav.daf.main.impl.config.telegrams.TransmitterInfo,short,String,String)
private void connectToTransmitter(TransmitterInfo t_info, short weight, String userName, String password) throws ConnectionException, CommunicationError
t_info
- Informationen zum Datenverteiler.weight
- Die Information wird von der Wegverwaltung benutzt, wenn eine Verbindung bewertet wird.userName
- Benutzername mit dem die Authentifizierung durchgeführt werden soll.password
- Passwort des Benutzers mit dem die Authentifizierung durchgeführt werden soll.
ConnectionException
- wenn eine Verbindung nicht aufgebaut werden konnte
CommunicationError
- wenn bei der initialen Kommunikation mit dem Datenverteiler Fehler aufgetreten sindprivate TransmitterConnectionInfo[] getInvolvedTransmitters(TransmitterInfo t_info)
t_info
- Information zum Datenverteiler
public long getApplicationId(String applicationTypePid, String applicationName) throws ConfigurationChangeException
applicationTypePid
- die Pid des ApplikationstypsapplicationName
- der Applikationsname
ConfigurationChangeException
- signalisiert Fehler bei Konfigurationsänderungenpublic long getConfigurationId(String configurationPid) throws ConfigurationException
configurationPid
- Die Pid der Konfiguration
ConfigurationException
- signalisiert Fehler bei Konfigurationsänderungenpublic long isValidUser(String userName, byte[] encriptedPassword, String authentificationText, AuthentificationProcess authentificationProcess, String typePid) throws ConfigurationException
userName
- BenutzernameencriptedPassword
- verschlüsseltes PasswortauthentificationText
- ZufallstextauthentificationProcess
- Namen des AuthentifizierungsverfahrenstypePid
- ID des Typs
ConfigurationException
- Fehler bei Konfigurationsänderungenpublic final void setLocalConfigurationAvaillable()
final void handleUserRightsChanged(long userId)
userId
- Identität des Benutzerspublic final void handleTransmitterSubscription(T_T_HighLevelCommunicationInterface connection, TransmitterDataSubscription subscription)
connection
- Schnittstelle "Datenverteiler-Datenverteiler"subscription
- Anmeldung von Daten des DAV für Empfänger oder Senderpublic final void handleTransmitterUnsubscription(T_T_HighLevelCommunicationInterface connection, TransmitterDataUnsubscription unsubscription)
connection
- Schnittstelle "Datenverteiler-Datenverteiler"unsubscription
- Abmeldung von Daten des DAV für Empfänger oder Senderpublic final void handleTransmitterSubscriptionReceip(T_T_HighLevelCommunicationInterface connection, TransmitterDataSubscriptionReceipt receiptTelegram)
connection
- Schnittstelle "Datenverteiler-Datenverteiler"receiptTelegram
- Quittung des DAV für eine an ihn gerichtete Datenanmeldung.final void handleTransmitterSubscriptionReceip(InAndOutSubscription subscription, long targetId, BaseSubscriptionInfo info, long mainTransmitterId, long[] transmitterIds, byte subscriptionState, byte receip)
final synchronized void handleTransmitterSubscriptionReceip(T_T_HighLevelCommunication connection, TransmitterDataSubscriptionReceipt
receipTelegram)
subscription
- Anmeldung TBD weitere Beschreibung, da InAndOutSubscription noch nicht kommentierttargetId
- Id des Kommunikationpartnersinfo
- DatenidentifikationmainTransmitterId
- Identität des Haupt-DAVtransmitterIds
- Liste von erreichbaren transmitternsubscriptionState
- Status der Anmeldungreceip
- Status der QuittunghandleTransmitterSubscriptionReceip(de.bsvrz.dav.dav.communication.davProtocol.T_T_HighLevelCommunicationInterface, de.bsvrz.dav.daf.communication.lowLevel.telegrams.TransmitterDataSubscriptionReceipt)
private final void handleNegativeReceip(InAndOutSubscription subscription)
final void handleTransmitterSubscriptionReceip(InAndOutSubscription subscription, long targetId, BaseSubscriptionInfo info, long
mainTransmitterId, long transmitterIds[],byte subscriptionState,byte receip)
. Behandelt eine negative Quittung einer Anmeldung.
subscription
- Anmeldung TBD weitere BeschreibunghandleTransmitterSubscriptionReceip(InAndOutSubscription,long,de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo,long,long[],byte,byte)
private void handleInvalidSubscription(InAndOutSubscription subscription, long mainTransmitterId)
private final void handleNegativeReceip(...)
Behandelt eine mehr als einmal positiv quittierte Anmeldung
subscription
- Anmeldung TBD weitere Beschreibung, da InAndOutSubscription noch nicht kommentiertmainTransmitterId
- ID des Zulieferer-DatenverteilerhandleTransmitterSubscriptionReceip(InAndOutSubscription,long,de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo,long,long[],byte,byte)
private void handlePositiveReceip(InAndOutSubscription subscription, byte receip, long mainTransmitterId)
subscription
- Anmeldung TBD weitere Beschreibung, da InAndOutSubscription noch nicht kommentiertreceip
- Status der QuittungmainTransmitterId
- ID des Zulieferer-DatenverteilerhandleTransmitterSubscriptionReceip(InAndOutSubscription,long,de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo,long,long[],byte,byte)
public void handleApplicationReceiveSubscription(T_A_HighLevelCommunication connection, ReceiveSubscriptionTelegram subscription)
connection
- Schnittstelle zwischen DAV und DAFsubscription
- Anmeldung als Emfänger oder Senkepublic void handleApplicationReceiveUnsubscription(T_A_HighLevelCommunication connection, ReceiveUnsubscriptionTelegram unsubscription)
connection
- Schnittstelle zwischen DAV und DAFunsubscription
- Abmeldetelegram der Applikationpublic void handleApplicationSendSubscription(T_A_HighLevelCommunication connection, SendSubscriptionTelegram subscription)
connection
- Schnittstelle zwischen DAV und DAFsubscription
- Anmeldetelegramm der Applikationpublic void handleApplicationSendUnsubscription(T_A_HighLevelCommunication connection, SendUnsubscriptionTelegram unsubscription)
connection
- Schnittstelle zwischen DAV und DAFunsubscription
- Abmeldetelegram der Applikationprivate void cleanPendingSubscriptionToRedirect(InAndOutSubscription subscription)
subscription
- Eintrag mit den Anmeldungsinformationenprivate void cleanPendingSubscriptionToRedirect(InAndOutSubscription subscription, OutSubscriptionsHelper subscriptionHelper)
subscription
- Eintrag mit den AnmeldungsinformationensubscriptionHelper
- private void workInvolvedSubscription(InAndOutSubscription involvedSubscription, OutSubscriptionsHelper subscriptionHelper)
involvedSubscription
- Eintrag mit den AnmeldungsinformationensubscriptionHelper
- private void makeOutgoingRequests(InAndOutSubscription request)
transmitterId
) in die Liste der potentiellen DAVs kopiert. Handelt es sich nicht um eine
Transmitterverbindung, so wird die Liste der erreichbaren Transmitter über listsManager.getPotentialTransmitters()
geholt. Anscließend wird die
Routine bestWayManager
aufgerufen, um die besten Wege von DAV zu DAV zu finden. Anscjhließend werden die von einem DAV erreichbaren DAVs in die
Liste outSubscription
gespeichert.
request
- Anmeldungsinformationenpublic void unsubscribeConnection(T_A_HighLevelCommunicationInterface connection)
connection
- die zu entfernende Verbindung zwischen DAV und Applicationpublic final void unsubscribeConnection(T_T_HighLevelCommunicationInterface connection)
connection
- die zu entfernende Verbindung zwischen DAV und DAVpublic T_T_HighLevelCommunication getTransmitterConnection(long communicationTransmitterId)
getTransmitterConnection
in interface ConnectionsManagerInterface
communicationTransmitterId
- Objekt-ID des Datenverteilers der über die gesuchte Verbindung erreicht werden kann.
null
, wenn keine direkte Verbindung zum angegebenen Datenverteiler vorhanden ist.final T_A_HighLevelCommunication getApplicationConnection(long applicationId)
applicationId
- die Id der verbundenen Applikation
public final void handleListsSubscription(T_T_HighLevelCommunicationInterface connection, TransmitterListsSubscription transmitterListsSubscription)
connection
- Verbindung zwischen DAV und DAVtransmitterListsSubscription
- AnmeldungsListe des Nachbardatenverteilerspublic final void handleListsUnsubscription(T_T_HighLevelCommunicationInterface connection, TransmitterListsUnsubscription transmitterListsUnsubscription)
connection
- Verbindung zwischen DAV und DAVtransmitterListsUnsubscription
- AbmeldungsListe des Nachbardatenverteilerspublic final void handleListsDeliveryUnsubscription(T_T_HighLevelCommunicationInterface connection, TransmitterListsDeliveryUnsubscription transmitterListsDeliveryUnsubscription)
connection
- Verbindung zwischen DAV und DAVtransmitterListsDeliveryUnsubscription
- Aufforderung zur Abmeldung der Zulieferdatenpublic final void handleListsUpdate(T_T_HighLevelCommunicationInterface connection, TransmitterListsUpdate transmitterListsUpdate)
connection
- Verbindung zwischen DAV und DAVtransmitterListsUpdate
- Aufforderung zur Aktualisierung der Zulieferinformaionfinal boolean updatePendingSubscription(BaseSubscriptionInfo info, long connectedTransmitterId, long dataIndex)
info
- DatenidentifikationconnectedTransmitterId
- ID des DAVdataIndex
- Datensatzindex
public final short getWeight(long connectedTransmitterId)
connectedTransmitterId
- ID des DAV
private final TransmitterConnectionInfo getTransmitterConnectionInfo(long connectedTransmitterId)
connectedTransmitterId
- ID des DAV
private final TransmitterConnectionInfo getRemoteTransmitterConnectionInfo(long connectedTransmitterId)
connectedTransmitterId
- ID des DAV
public String getUserNameForAuthentification(long connectedTransmitterId)
connectedTransmitterId
- Objekt-ID des anderen Datenverteilers.
public String getPasswordForAuthentification(long connectedTransmitterId)
connectedTransmitterId
- Objekt-ID des anderen Datenverteilers.
public final void updateDestinationRoute(long _transmitterId, RoutingConnectionInterface oldConnection, RoutingConnectionInterface newConnection)
DistributionInterface
updateDestinationRoute
in interface DistributionInterface
_transmitterId
- ID des betroffenen Datenverteilers.oldConnection
- Verbindung über die bisher mit dem betroffenen Datenverteiler kommuniziert wurde.newConnection
- Verbindung über die in Zukunft mit dem betroffenen Datenverteiler kommuniziert werden soll.public final void close(boolean error, String message)
error
- True: ein Fehler ist aufgetretenmessage
- genauere Beschreibung des Fehlersprivate List getTransmitterConnections(long userId)
userId
- ID des Benutzers
private final List getApplicationConnections(long userId)
userId
- ID des Benutzers
private void removeTransmitterConnection(long communicationTransmitterId)
communicationTransmitterId
- Id des verbundenen Datenverteilersprivate final SystemObject removeApplicationConnection(long applicationId)
applicationId
- Id der verbundenen Applikation
public void printSubscriptions()
subscriptionsManager.printSubscriptions
auf, welche die Anmeldeinformationen in den OutputSream schreibt.
public void setLocaleModeParameter(String configurationPid, long configurationId)
configurationPid
- Pid der KonfigurationsapplikationconfigurationId
- Id der Konfigurationsapplikationpublic String getLocaleModeConfigurationPid()
configurationPid
public long getLocaleModeConfigurationId()
configurationId
public ServerDavParameters getServerDavParameters()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |