public class SubscriptionManager extends Object
Constructor and Description |
---|
SubscriptionManager(ClientDavParameters dafParameters) |
Modifier and Type | Method and Description |
---|---|
void |
addConfiguration(ConfigurationManager configurationManager,
String name)
Fügt einen ConfigurationManager für eine entfernte Konfiguration hinzu
|
void |
close()
Schließt diese Subkomponente und terminiert den Aktualisierungsthread.
|
void |
completeInitialisation(boolean skipConfiguration)
Initialisierung der Anmeldungsverwaltung.
|
ClientHighLevelCommunication |
getHighLevelCommunication()
Bestimmt die Kommunikationsschicht von der der SubscriptionManager abhängig ist
|
List<ConfigurationManager> |
getSecondaryConfigurationManagers()
Gibt eine Liste mit ConfigurationManagern zurück, die entfernte Konfigurationen verwalten
|
int |
getTimeStampFromSenderSubscription(BaseSubscriptionInfo info)
Gibt den Zeitpunkt einer Sender-Anmeldung zurück
|
boolean |
isInitialisationComplete()
Überprüft, ob die notwendigen Anmeldungen einer gerichtete Kommunikation durch die Konfiguration erfolgt sind oder nicht.
|
void |
notifySenderApplication(BaseSubscriptionInfo info,
byte state)
Wenn eine Sendeanmeldung mit aktivierter Benachrichtigungsoption vorliegt, dann wird ihr über diese Methode mitgeteilt, welche Aktion von ihr durchzuführen
ist.
|
void |
sendData(ResultData result)
Sendet einen Ergebnisdatensatz zum Datenverteiler.
|
void |
setConfigurationManager(ConfigurationManager configurationManager)
Setzt den ConfigurationManager dieser Subkomponente und benachrichtigt die Protokollsteuerung DaV-DAF über die Bereitschaft, Konfigurationsdaten zu
empfangen.
|
void |
setHighLevelCommunication(ClientHighLevelCommunication highLevelCommunication)
Setzt die ClientHighLevelCommunication-Subkomponente um Anmeldungen, Abmeldungen und Datensätze an den Datenverteiler weiterzuleiten.
|
void |
subscribeReceiver(ClientReceiverInterface receiver,
SystemObject[] objects,
DataDescription dataDescription,
ReceiveOptions options,
ReceiverRole role,
long cacheTime)
Anmeldung zum Empfangen von Daten.
|
void |
subscribeSender(ClientSenderInterface sender,
SystemObject[] objects,
DataDescription dataDescription,
SenderRole role)
Anmeldung zum Senden von Daten.
|
void |
unsubscribeReceiver(ClientReceiverInterface receiver,
SystemObject[] objects,
DataDescription dataDescription)
Abmeldung von angemeldeten Daten.
|
void |
unsubscribeSender(ClientSenderInterface sender,
SystemObject[] objects,
DataDescription dataDescription)
Abmeldung von angemeldeten Daten.
|
void |
waitForInitialization(long configAuthorityId)
Wartet auf den Verbindungsaufbau zu einer Konfiguration
|
public SubscriptionManager(ClientDavParameters dafParameters)
dafParameters
- Startparameter der Verbindungpublic final void setHighLevelCommunication(ClientHighLevelCommunication highLevelCommunication)
highLevelCommunication
- Referenz auf die zu setzende Kommunikationsschichtpublic final ClientHighLevelCommunication getHighLevelCommunication()
public final void completeInitialisation(boolean skipConfiguration)
skipConfiguration
- Anmeldung von Konfigurationsanfragen unterdrückenpublic final boolean isInitialisationComplete()
public final void setConfigurationManager(ConfigurationManager configurationManager)
configurationManager
- Referenz auf den zu setzenden Konfigurationsmanagerpublic final void subscribeReceiver(ClientReceiverInterface receiver, SystemObject[] objects, DataDescription dataDescription, ReceiveOptions options, ReceiverRole role, long cacheTime)
receiver
- Ein von der Applikation bereitzustellendes Objekt, das bei Aktualisierungen entsprechende Methodenaufrufe erhält.objects
- Liste mit System-Objekten für die die spezifizierten Daten anzumelden sind.dataDescription
- Beschreibende Informationen zu den anzumeldenden Daten.options
- Für die Anmeldung zu verwendende Optionen.role
- Für die Anmeldung zu verwendende Rolle (Empfänger oder Senke).cacheTime
- Vorhaltezeitraum in Millisekunden. Der Vorhaltezeitraum spezifiziert, wie lange empfangene Daten zwischengespeichert werden sollen.IllegalArgumentException
- Die angegebene ReceiverRole verstößt gegen die Attributgruppenverwendung.public int getTimeStampFromSenderSubscription(BaseSubscriptionInfo info)
info
- Anmeldungpublic final void unsubscribeReceiver(ClientReceiverInterface receiver, SystemObject[] objects, DataDescription dataDescription)
subscribeReceiver(de.bsvrz.dav.daf.main.impl.subscription.ReceiverSubscription)
durchgeführte Empfangsanmeldung wieder rückgängig.receiver
- Das Anwendungsobjekt, das bei der Anmeldung benutzt wurde.objects
- Feld mit System-Objekten für die die spezifizierten Daten abzumelden sind.dataDescription
- Beschreibende Informationen zu den abzumeldenden Daten.public final void subscribeSender(ClientSenderInterface sender, SystemObject[] objects, DataDescription dataDescription, SenderRole role) throws OneSubscriptionPerSendData
sender
- Applikationsobjekt zur Verarbeitung von Sendesteuerungenobjects
- Feld mit System-Objekten für die spezifizierten Daten anzumelden sind.dataDescription
- Beschreibende Informationen zu den anzumeldenden Daten.role
- Für die Anmeldung zu verwendende Rolle (Quelle oder Sender).IllegalArgumentException
- Die SenderRole verstößt gegen die AttributgruppenverwendungOneSubscriptionPerSendData
- Wenn bereits eine lokale Sendeanmeldung für diese Datenidentifikation vorhanden istpublic final void unsubscribeSender(ClientSenderInterface sender, SystemObject[] objects, DataDescription dataDescription)
subscribeSender(de.bsvrz.dav.daf.main.ClientSenderInterface, de.bsvrz.dav.daf.main.config.SystemObject[], de.bsvrz.dav.daf.main.DataDescription, de.bsvrz.dav.daf.main.SenderRole)
durchgeführte Sendeanmeldung wieder rückgängig.sender
- Das Anwendungsobjekt, das bei der Anmeldung benutzt wurde.objects
- Feld mit System-Objekten für die die spezifizierten Daten abzumelden sind.dataDescription
- Beschreibende Informationen zu den abzumeldenden Daten.public final void sendData(ResultData result) throws DataNotSubscribedException, SendSubscriptionNotConfirmed
result
- Ergebnis mit dem zu sendenden Datensatz.DataNotSubscribedException
- Wenn die Daten nicht zum Senden angemeldet waren.SendSubscriptionNotConfirmed
- Wenn die Sendesteuerung abgewartet werden muss, bevor gesendet werden kann.public void notifySenderApplication(BaseSubscriptionInfo info, byte state)
info
- Anmeldeinfo, auf die sich die Sendesteuerung beziehtstate
- Zustand der Sendesteuerungpublic final void close()
public void addConfiguration(ConfigurationManager configurationManager, String name)
configurationManager
- ConfigurationManagername
- Name der Konfigurationpublic List<ConfigurationManager> getSecondaryConfigurationManagers()
public void waitForInitialization(long configAuthorityId) throws ConfigurationTaskException
configAuthorityId
- Konfigurationsverantwortlichen-IdConfigurationTaskException