Package de.bsvrz.dav.dav.subscriptions
Class LocalReceivingSubscription
- java.lang.Object
-
- de.bsvrz.dav.dav.subscriptions.LocalReceivingSubscription
-
- All Implemented Interfaces:
LocalSubscription,ReceivingSubscription,Subscription
public class LocalReceivingSubscription extends java.lang.Object implements LocalSubscription, ReceivingSubscription
-
-
Constructor Summary
Constructors Constructor Description LocalReceivingSubscription(SubscriptionsManager subscriptionsManager, de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo, boolean drain, de.bsvrz.dav.daf.main.ReceiveOptions receiveOptions, ApplicationCommunicationInterface applicationConnection)
-
Method Summary
Modifier and Type Method Description de.bsvrz.dav.daf.communication.protocol.UserLogingetAuthenticationState()Gibt die Id des angemeldeten Benutzers zurück.de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfogetBaseSubscriptionInfo()Gibt die Objekt-Attributgruppenverwendung-Simulationsvariante-Kombination zurück, auf die diese Anmeldung stattfindetlonggetCentralDistributorId()Gibt die Zentraldatenverteiler-ID zurück.ApplicationCommunicationInterfacegetCommunication()Gibt die Schnittstelle zum Kommunikationspartner zurück, also z.B. eine T_A oder T_T-VerbindungConnectionStategetConnectionState()Gibt den Verbindungsstatus zum Kommunikationspartner zurücklonggetNodeId()Liefert die Id der anmeldenden Applikation bzw. des anmeldenden Datenverteilers (nicht zwingend der direkt verbundene Datenverteiler, sondern der Kommunikationspartner, der die Daten bereitstellt oder empfängt)de.bsvrz.dav.daf.main.ReceiveOptionsgetReceiveOptions()Gibt die Empfangsoptionen zurück, die der Empfänger bei der Anmeldung spezifiziert hatReceiverStategetState()Gibt den Status des Empfängers zurückbooleanisAllowed()Gibt zurück, ob die Anmeldung von der lokalen Rechteprüfung erlaubt istbooleanisDrain()Gibttruezurück, wenn es sich um eine Senke handeltvoidsendDataTelegram(de.bsvrz.dav.daf.communication.lowLevel.telegrams.ApplicationDataTelegram applicationDataTelegram, long applicationId)Sendet Daten an den EmpfängervoidsendStateTelegram(ReceiverState receiverState)Sendet an einen Empfänger falls nötig im Falle eines geänderten Anmeldestatus einen leeren Datensatz mit dem entsprechenden Inhalt.voidsetState(ReceiverState receiverState, long centralTransmitterId)Setzt den Status des Empfängersjava.lang.StringtoString()voidunsubscribe()Beendet die Datenanmeldung, sendet eventuelle Abmeldetelegramme
-
-
-
Constructor Detail
-
LocalReceivingSubscription
public LocalReceivingSubscription(SubscriptionsManager subscriptionsManager, de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo, boolean drain, de.bsvrz.dav.daf.main.ReceiveOptions receiveOptions, ApplicationCommunicationInterface applicationConnection)
-
-
Method Detail
-
getNodeId
public long getNodeId()
Description copied from interface:SubscriptionLiefert die Id der anmeldenden Applikation bzw. des anmeldenden Datenverteilers (nicht zwingend der direkt verbundene Datenverteiler, sondern der Kommunikationspartner, der die Daten bereitstellt oder empfängt)- Specified by:
getNodeIdin interfaceSubscription- Returns:
- Id der Applikation (bei T_A-Verbindungen) oder Id des Datenverteilers (bei T_T-Verbindungen)
-
getConnectionState
public ConnectionState getConnectionState()
Description copied from interface:SubscriptionGibt den Verbindungsstatus zum Kommunikationspartner zurück- Specified by:
getConnectionStatein interfaceSubscription- Returns:
- Verbindugnsstatus
-
getCentralDistributorId
public long getCentralDistributorId()
Description copied from interface:SubscriptionGibt die Zentraldatenverteiler-ID zurück. Nur sinnvoll bei Quelle/Senke-Anmeldungen. Ist der Zentraldatenverteiler unbekannt, wird -1 zurückgegeben.- Specified by:
getCentralDistributorIdin interfaceSubscription- Returns:
- die Zentraldatenverteiler-ID
-
unsubscribe
public void unsubscribe()
Description copied from interface:SubscriptionBeendet die Datenanmeldung, sendet eventuelle Abmeldetelegramme- Specified by:
unsubscribein interfaceSubscription
-
getCommunication
public ApplicationCommunicationInterface getCommunication()
Description copied from interface:SubscriptionGibt die Schnittstelle zum Kommunikationspartner zurück, also z.B. eine T_A oder T_T-Verbindung- Specified by:
getCommunicationin interfaceLocalSubscription- Specified by:
getCommunicationin interfaceSubscription- Returns:
- die Schnittstelle zum Kommunikationspartner
-
isDrain
public boolean isDrain()
Description copied from interface:ReceivingSubscriptionGibttruezurück, wenn es sich um eine Senke handelt- Specified by:
isDrainin interfaceReceivingSubscription- Returns:
true, wenn es sich um eine Senke handelt, sonst (Empfänger)false
-
getReceiveOptions
public de.bsvrz.dav.daf.main.ReceiveOptions getReceiveOptions()
Description copied from interface:ReceivingSubscriptionGibt die Empfangsoptionen zurück, die der Empfänger bei der Anmeldung spezifiziert hat- Specified by:
getReceiveOptionsin interfaceReceivingSubscription- Returns:
- die Empfangsoptionen
-
sendDataTelegram
public void sendDataTelegram(de.bsvrz.dav.daf.communication.lowLevel.telegrams.ApplicationDataTelegram applicationDataTelegram, long applicationId)Description copied from interface:ReceivingSubscriptionSendet Daten an den Empfänger- Specified by:
sendDataTelegramin interfaceReceivingSubscription- Parameters:
applicationDataTelegram- TelegrammapplicationId- oder -1 falls nicht bekannt
-
getState
public ReceiverState getState()
Description copied from interface:ReceivingSubscriptionGibt den Status des Empfängers zurück- Specified by:
getStatein interfaceReceivingSubscription- Returns:
- den Status des Empfängers
-
setState
public void setState(ReceiverState receiverState, long centralTransmitterId)
Description copied from interface:ReceivingSubscriptionSetzt den Status des Empfängers- Specified by:
setStatein interfaceReceivingSubscription- Parameters:
receiverState- neuer Status
-
sendStateTelegram
public void sendStateTelegram(ReceiverState receiverState)
Sendet an einen Empfänger falls nötig im Falle eines geänderten Anmeldestatus einen leeren Datensatz mit dem entsprechenden Inhalt.- Specified by:
sendStateTelegramin interfaceReceivingSubscription- Parameters:
receiverState- Empfängerstatus
-
getBaseSubscriptionInfo
public de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo getBaseSubscriptionInfo()
Description copied from interface:SubscriptionGibt die Objekt-Attributgruppenverwendung-Simulationsvariante-Kombination zurück, auf die diese Anmeldung stattfindet- Specified by:
getBaseSubscriptionInfoin interfaceSubscription- Returns:
- BaseSubscriptionInfo
-
isAllowed
public boolean isAllowed()
Description copied from interface:SubscriptionGibt zurück, ob die Anmeldung von der lokalen Rechteprüfung erlaubt ist- Specified by:
isAllowedin interfaceSubscription- Returns:
-
getAuthenticationState
public de.bsvrz.dav.daf.communication.protocol.UserLogin getAuthenticationState()
Description copied from interface:SubscriptionGibt die Id des angemeldeten Benutzers zurück. Liefert das gleiche wie getCommunication().getRemoteUserId()- Specified by:
getAuthenticationStatein interfaceSubscription- Returns:
- Id den angemeldeten Benutzers
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-