public class HighLevelSubscriptionsManager extends AbstractSubscriptionsManager
SubscriptionInfo
) erstellt, welche den Status der angemeldeten Applikationen und Datenverteiler ermitteln und entsprechend
veröffentlichen.Modifier and Type | Field and Description |
---|---|
private AccessControlManager |
_accessControlManager
Verwaltungsklasse für Zugriffsrechte
|
private ApplicationStatusUpdater |
_applicationStatusUpdater |
private ClientDavConnection |
_connection
Eigene Applikation-Verbindung zum Datenverteiler
|
private HighLevelConnectionsManagerInterface |
_connectionsManager
Verbindungsverwaltung
|
private static Debug |
_debug |
private TelegramManager |
_telegramManager
Verwaltungsklasse für Telegramme
|
private ServerDavParameters.UserRightsChecking |
_userRightsChecking
Legt fest, ob die Rechteprüfung aktiviert ist
|
_dataIndexCounter, _subscriptions
Constructor and Description |
---|
HighLevelSubscriptionsManager(TelegramManager telegramManager,
ServerDavParameters.UserRightsChecking userRightsChecking)
Initialisiert den Anmeldungsmanager
|
Modifier and Type | Method and Description |
---|---|
void |
addLocalReceiveSubscription(ApplicationCommunicationInterface application,
ReceiveSubscriptionInfo receiveSubscriptionInfo)
Meldet einen lokalen Empfänger oder eine lokale Senke an
|
void |
addLocalSendSubscription(ApplicationCommunicationInterface application,
SendSubscriptionInfo sendSubscriptionInfo)
Meldet einen lokalen Sender oder eine lokale Quelle an
|
(package private) AccessControlManager |
getAccessControlManager()
Gibt den AccessControlManager zurück
|
Collection<? extends Subscription> |
getAllSubscriptions(long applicationId) |
T_T_HighLevelCommunicationInterface |
getBestConnectionToRemoteDav(long remoteDav)
Gibt die beste Verbindung zum angegebenen Datenverteiler zurück
|
List<Long> |
getPotentialCentralDistributors(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,
AttributeGroupAspectCombination[] attributeGroupAspectCombinations)
Wird bei einem Update der Anmeldelisten aufgerufen.
|
void |
initializeUser(long userId) |
boolean |
isActionAllowed(long userId,
BaseSubscriptionInfo info,
UserAction action)
Führt eine Rechteprüfung durch
|
void |
notifyIsNewCentralDistributor(BaseSubscriptionInfo baseSubscriptionInfo)
Wird aufgerufen, wenn dieser Datenverteiler für eine Anmeldung Zentraldatenverteiler geworden ist, z.B.
|
void |
notifyWasCentralDistributor(BaseSubscriptionInfo baseSubscriptionInfo)
Wird aufgerufen, wenn dieser Datenverteiler für eine Anmeldung nicht mehr Zentraldatenverteiler ist, z.B.
|
String |
objectToString(long objectId)
Formatiert eine Id zu einem Text der sich in Fehlerausgaben und ähnlichem eignet
|
void |
removeLocalReceiveSubscriptions(ApplicationCommunicationInterface application,
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,
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 anhängen (z.B.
|
String |
subscriptionToString(BaseSubscriptionInfo baseSubscriptionInfo)
Formatiert eine baseSubscriptionInfo zu einem String, der sich zur Darstellung in Fehlerausgaben u.ä.
|
connectToRemoteDrains, connectToRemoteSources, dataIndexToString, getAllSubscriptions, getCurrentDataIndex, getNextDataIndex, getNextDataIndex, getSubscriptionInfo, handleTransmitterSubscriptionReceipt, handleUserRightsChanged, openExistingSubscriptionInfo, openSubscriptionInfo, removeAllSubscriptions, removeAllSubscriptions, removeSubscriptionInfo, updateDestinationRoute
private final HighLevelConnectionsManagerInterface _connectionsManager
private final ServerDavParameters.UserRightsChecking _userRightsChecking
private volatile AccessControlManager _accessControlManager
private final TelegramManager _telegramManager
private volatile ClientDavConnection _connection
private ApplicationStatusUpdater _applicationStatusUpdater
private static final Debug _debug
public HighLevelSubscriptionsManager(TelegramManager telegramManager, ServerDavParameters.UserRightsChecking 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, SendSubscriptionInfo sendSubscriptionInfo)
AbstractSubscriptionsManager
addLocalSendSubscription
in class AbstractSubscriptionsManager
application
- VerbindungsendSubscriptionInfo
- Anmeldeparameterpublic void removeLocalSendSubscription(ApplicationCommunicationInterface application, BaseSubscriptionInfo baseSubscriptionInfo)
AbstractSubscriptionsManager
removeLocalSendSubscription
in class AbstractSubscriptionsManager
application
- VerbindungbaseSubscriptionInfo
- Objekt und Attributgruppenverwendungpublic void addLocalReceiveSubscription(ApplicationCommunicationInterface application, ReceiveSubscriptionInfo receiveSubscriptionInfo)
AbstractSubscriptionsManager
addLocalReceiveSubscription
in class AbstractSubscriptionsManager
application
- VerbindungreceiveSubscriptionInfo
- Anmeldeparameterpublic void removeLocalReceiveSubscriptions(ApplicationCommunicationInterface application, BaseSubscriptionInfo baseSubscriptionInfo)
AbstractSubscriptionsManager
removeLocalReceiveSubscriptions
in class AbstractSubscriptionsManager
application
- VerbindungbaseSubscriptionInfo
- Objekt und Attributgruppenverwendungpublic final boolean isActionAllowed(long userId, BaseSubscriptionInfo info, UserAction action)
userId
- Benutzer-IDinfo
- Anmeldeinfoaction
- Aktionpublic String subscriptionToString(BaseSubscriptionInfo baseSubscriptionInfo)
baseSubscriptionInfo
- baseSubscriptionInfopublic String objectToString(long objectId)
objectId
- Idpublic long getThisTransmitterId()
SubscriptionsManager
AccessControlManager getAccessControlManager()
public void notifyIsNewCentralDistributor(BaseSubscriptionInfo baseSubscriptionInfo)
baseSubscriptionInfo
- public void notifyWasCentralDistributor(BaseSubscriptionInfo baseSubscriptionInfo)
baseSubscriptionInfo
- public TelegramManager getTelegramManager()
public List<Long> getPotentialCentralDistributors(BaseSubscriptionInfo baseSubscriptionInfo)
SubscriptionsManager
baseSubscriptionInfo
- Anmeldungpublic T_T_HighLevelCommunicationInterface getBestConnectionToRemoteDav(long remoteDav)
SubscriptionsManager
public void handleListsUpdate(long[] objectIds, AttributeGroupAspectCombination[] attributeGroupAspectCombinations)
objectIds
- Neue ObjekteattributeGroupAspectCombinations
- Neue Attributgruppenverwendungenpublic 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