SubscriptionsManager
public class HighLevelSubscriptionsManager extends AbstractSubscriptionsManager
SubscriptionInfo
) erstellt, welche den Status der angemeldeten Applikationen und Datenverteiler ermitteln und entsprechend
veröffentlichen._dataIndexCounter, _subscriptions
Constructor | Description |
---|---|
HighLevelSubscriptionsManager(TelegramManager telegramManager,
de.bsvrz.dav.daf.accessControl.AccessControlMode userRightsChecking) |
Initialisiert den Anmeldungsmanager
|
Modifier and Type | Method | Description |
---|---|---|
void |
addLocalReceiveSubscription(ApplicationCommunicationInterface application,
de.bsvrz.dav.daf.communication.lowLevel.telegrams.ReceiveSubscriptionInfo receiveSubscriptionInfo) |
Meldet einen lokalen Empfänger oder eine lokale Senke an
|
void |
addLocalSendSubscription(ApplicationCommunicationInterface application,
de.bsvrz.dav.daf.communication.lowLevel.telegrams.SendSubscriptionInfo sendSubscriptionInfo) |
Meldet einen lokalen Sender oder eine lokale Quelle an
|
java.util.Collection<? extends Subscription> |
getAllSubscriptions(long applicationId) |
|
T_T_HighLevelCommunicationInterface |
getBestConnectionToRemoteDav(long remoteDav) |
Gibt die beste Verbindung zum angegebenen Datenverteiler zurück
|
java.util.List<java.lang.Long> |
getPotentialCentralDistributors(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo) |
Gibt zu einer Anmeldungen die potentiellen Zentraldatenverteiler zurück
|
TelegramManager |
getTelegramManager() |
|
long |
getThisTransmitterId() |
Gibt die eigene Dav-ID zurück
|
void |
handleListsUpdate(long[] objectIds,
de.bsvrz.dav.daf.communication.lowLevel.telegrams.AttributeGroupAspectCombination[] attributeGroupAspectCombinations) |
Wird bei einem Update der Anmeldelisten aufgerufen.
|
void |
initializeUser(long userId) |
Initialisiert die Zugriffsrechte für den angegebenen Benutzer
|
boolean |
isActionAllowed(de.bsvrz.dav.daf.communication.protocol.UserLogin userLogin,
de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo info,
de.bsvrz.dav.daf.accessControl.internal.UserAction action) |
Führt eine allgemeine Rechteprüfung durch
|
boolean |
isActionAllowed(ApplicationCommunicationInterface application,
de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo info,
de.bsvrz.dav.daf.accessControl.internal.UserAction action) |
Führt eine Rechteprüfung bei einer lokalen Anmeldung durch.
|
void |
notifyIsNewCentralDistributor(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo) |
Wird aufgerufen, wenn dieser Datenverteiler für eine Anmeldung Zentraldatenverteiler geworden ist, z.B. um die Anmeldelisten zu aktualisieren
|
void |
notifyWasCentralDistributor(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo) |
Wird aufgerufen, wenn dieser Datenverteiler für eine Anmeldung nicht mehr Zentraldatenverteiler ist, z.B. um die Anmeldelisten zu aktualisieren
|
java.lang.String |
objectToString(long objectId) |
Formatiert eine Id zu einem Text der sich in Fehlerausgaben und ähnlichem eignet
|
void |
removeLocalReceiveSubscriptions(ApplicationCommunicationInterface application,
de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo) |
Meldet einen lokalen Empfänger oder eine lokale Senke ab.
|
void |
removeLocalReceiveSubscriptions(ApplicationCommunicationInterface application,
SubscriptionInfo subscriptionInfo) |
Meldet einen lokalen Empfänger oder eine lokale Senke ab.
|
void |
removeLocalSendSubscription(ApplicationCommunicationInterface application,
de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo) |
Meldet einen lokalen Sender oder eine lokale Quelle ab.
|
void |
removeLocalSendSubscriptions(ApplicationCommunicationInterface application,
SubscriptionInfo subscriptionInfo) |
Meldet einen lokalen Senker oder eine lokale Quelle ab.
|
void |
setConfigurationAvailable(SelfClientDavConnection selfClientDavConnection,
ApplicationStatusUpdater applicationStatusUpdater) |
Initialisiert Funktionen, die von der Konfiguration abhängen (z.B.
|
java.lang.String |
subscriptionToString(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo) |
Formatiert eine baseSubscriptionInfo zu einem String, der sich zur Darstellung in Fehlerausgaben u.ä. eignet
|
connectToRemoteDrains, connectToRemoteSources, dataIndexToString, getAllSubscriptions, getCurrentDataIndex, getNextDataIndex, getNextDataIndex, getSubscriptionInfo, handleTransmitterSubscriptionReceipt, handleUserRightsChanged, openExistingSubscriptionInfo, openSubscriptionInfo, removeAllSubscriptions, removeAllSubscriptions, removeSubscriptionInfo, updateDestinationRoute
public HighLevelSubscriptionsManager(TelegramManager telegramManager, de.bsvrz.dav.daf.accessControl.AccessControlMode userRightsChecking)
telegramManager
- Telegramm-ManageruserRightsChecking
- Ob die Zugriffsrechteprüfung aktiviert istpublic void setConfigurationAvailable(SelfClientDavConnection selfClientDavConnection, ApplicationStatusUpdater applicationStatusUpdater)
selfClientDavConnection
- eigene Datenverteiler-VerbindungapplicationStatusUpdater
- Klasse, die angemeldete Datensätze verschicktpublic void addLocalSendSubscription(ApplicationCommunicationInterface application, de.bsvrz.dav.daf.communication.lowLevel.telegrams.SendSubscriptionInfo sendSubscriptionInfo)
AbstractSubscriptionsManager
addLocalSendSubscription
in class AbstractSubscriptionsManager
application
- VerbindungsendSubscriptionInfo
- Anmeldeparameterpublic void removeLocalSendSubscription(ApplicationCommunicationInterface application, de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo)
AbstractSubscriptionsManager
removeLocalSendSubscription
in class AbstractSubscriptionsManager
application
- VerbindungbaseSubscriptionInfo
- Objekt und Attributgruppenverwendungpublic void addLocalReceiveSubscription(ApplicationCommunicationInterface application, de.bsvrz.dav.daf.communication.lowLevel.telegrams.ReceiveSubscriptionInfo receiveSubscriptionInfo)
AbstractSubscriptionsManager
addLocalReceiveSubscription
in class AbstractSubscriptionsManager
application
- VerbindungreceiveSubscriptionInfo
- Anmeldeparameterpublic void removeLocalReceiveSubscriptions(ApplicationCommunicationInterface application, de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo)
AbstractSubscriptionsManager
removeLocalReceiveSubscriptions
in class AbstractSubscriptionsManager
application
- VerbindungbaseSubscriptionInfo
- Objekt und Attributgruppenverwendungpublic boolean isActionAllowed(ApplicationCommunicationInterface application, de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo info, de.bsvrz.dav.daf.accessControl.internal.UserAction action)
SubscriptionsManager
application
- Applikationinfo
- Anmeldeinfoaction
- Aktionpublic final boolean isActionAllowed(de.bsvrz.dav.daf.communication.protocol.UserLogin userLogin, de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo info, de.bsvrz.dav.daf.accessControl.internal.UserAction action)
SubscriptionsManager
userLogin
- Benutzer-IDinfo
- Anmeldeinfoaction
- Aktionpublic java.lang.String subscriptionToString(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo)
baseSubscriptionInfo
- baseSubscriptionInfopublic java.lang.String objectToString(long objectId)
objectId
- Idpublic long getThisTransmitterId()
SubscriptionsManager
public void notifyIsNewCentralDistributor(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo)
baseSubscriptionInfo
- public void notifyWasCentralDistributor(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo)
baseSubscriptionInfo
- public TelegramManager getTelegramManager()
public java.util.List<java.lang.Long> getPotentialCentralDistributors(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo)
SubscriptionsManager
baseSubscriptionInfo
- Anmeldungpublic T_T_HighLevelCommunicationInterface getBestConnectionToRemoteDav(long remoteDav)
SubscriptionsManager
remoteDav
- Datenverteiler-IDpublic void handleListsUpdate(long[] objectIds, de.bsvrz.dav.daf.communication.lowLevel.telegrams.AttributeGroupAspectCombination[] attributeGroupAspectCombinations)
objectIds
- Neue ObjekteattributeGroupAspectCombinations
- Neue Attributgruppenverwendungenpublic java.util.Collection<? extends Subscription> getAllSubscriptions(long applicationId)
public void removeLocalSendSubscriptions(ApplicationCommunicationInterface application, SubscriptionInfo subscriptionInfo)
removeLocalSendSubscriptions
in class AbstractSubscriptionsManager
application
- AnwendungsubscriptionInfo
- subscriptionInfopublic void removeLocalReceiveSubscriptions(ApplicationCommunicationInterface application, SubscriptionInfo subscriptionInfo)
removeLocalReceiveSubscriptions
in class AbstractSubscriptionsManager
application
- AnwendungsubscriptionInfo
- subscriptionInfopublic void initializeUser(long userId)
initializeUser
in class AbstractSubscriptionsManager
userId
- Benutzer-ID (muss in der lokalen Konfiguration existieren)