public class RemoteDrainSubscription extends java.lang.Object implements RemoteReceivingSubscription, RemoteCentralSubscription
Anmeldung als Sender auf eine Senke bei einem entfernten Zentral-Datenverteiler.
| Modifier and Type | Field and Description |
|---|---|
private BaseSubscriptionInfo |
_baseSubscriptionInfo |
private long |
_centralDistributor |
private ConnectionState |
_connectionState |
private java.util.Set<java.lang.Long> |
_potentialCentralDistributors |
private ReceiverState |
_receiverState |
private SubscriptionsManager |
_subscriptionsManager |
private TransmitterCommunicationInterface |
_transmitterCommunication |
| Constructor and Description |
|---|
RemoteDrainSubscription(SubscriptionsManager subscriptionsManager,
BaseSubscriptionInfo baseSubscriptionInfo,
TransmitterCommunicationInterface connectionToRemoteDav) |
| Modifier and Type | Method and Description |
|---|---|
void |
addPotentialDistributor(long transmitterId) |
UserLogin |
getAuthenticationState()
Gibt die Id des angemeldeten Benutzers zurück.
|
BaseSubscriptionInfo |
getBaseSubscriptionInfo()
Gibt die Objekt-Attributgruppenverwendung-Simulationsvariante-Kombination zurück, auf die diese Anmeldung stattfindet
|
long |
getCentralDistributorId()
Gibt die Zentraldatenverteiler-ID zurück.
|
TransmitterCommunicationInterface |
getCommunication()
Gibt die Schnittstelle zum Kommunikationspartner zurück, also z.B. eine T_A oder T_T-Verbindung
|
ConnectionState |
getConnectionState()
Gibt den Verbindungsstatus zum Kommunikationspartner zurück
|
long |
getNodeId()
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)
|
java.util.Set<java.lang.Long> |
getPotentialDistributors() |
ReceiveOptions |
getReceiveOptions()
Gibt die Empfangsoptionen zurück, die der Empfänger bei der Anmeldung spezifiziert hat
|
ReceiverState |
getState()
Gibt den Status des Empfängers zurück
|
boolean |
isAllowed()
Gibt zurück, ob die Anmeldung von der lokalen Rechteprüfung erlaubt ist
|
boolean |
isDrain()
Gibt true zurück, wenn es sich um eine Senke handelt
|
void |
removePotentialDistributor(long transmitterId) |
void |
sendDataTelegram(ApplicationDataTelegram applicationDataTelegram)
Sendet Daten an den Empfänger
|
void |
sendStateTelegram(ReceiverState receiverState) |
void |
setPotentialDistributors(java.util.Collection<java.lang.Long> value) |
void |
setRemoteState(long mainTransmitterId,
ConnectionState state) |
void |
setState(ReceiverState receiverState,
long centralTransmitterId)
Setzt den Status des Empfängers
|
void |
subscribe() |
java.lang.String |
toString() |
void |
unsubscribe()
Beendet die Datenanmeldung, sendet eventuelle Abmeldetelegramme
|
private final SubscriptionsManager _subscriptionsManager
private long _centralDistributor
private final TransmitterCommunicationInterface _transmitterCommunication
private final BaseSubscriptionInfo _baseSubscriptionInfo
private ReceiverState _receiverState
private ConnectionState _connectionState
private final java.util.Set<java.lang.Long> _potentialCentralDistributors
public RemoteDrainSubscription(SubscriptionsManager subscriptionsManager, BaseSubscriptionInfo baseSubscriptionInfo, TransmitterCommunicationInterface connectionToRemoteDav)
public final void subscribe()
subscribe in interface RemoteCentralSubscriptionpublic java.util.Set<java.lang.Long> getPotentialDistributors()
getPotentialDistributors in interface RemoteSubscriptionpublic void setPotentialDistributors(java.util.Collection<java.lang.Long> value)
setPotentialDistributors in interface RemoteSubscriptionpublic void addPotentialDistributor(long transmitterId)
addPotentialDistributor in interface RemoteSubscriptionpublic void removePotentialDistributor(long transmitterId)
removePotentialDistributor in interface RemoteSubscriptionpublic boolean isDrain()
ReceivingSubscriptionGibt true zurück, wenn es sich um eine Senke handelt
isDrain in interface ReceivingSubscriptionpublic long getCentralDistributorId()
SubscriptionGibt die Zentraldatenverteiler-ID zurück. Nur sinnvoll bei Quelle/Senke-Anmeldungen. Ist der Zentraldatenverteiler unbekannt, wird -1 zurückgegeben.
getCentralDistributorId in interface Subscriptionpublic ReceiveOptions getReceiveOptions()
ReceivingSubscriptionGibt die Empfangsoptionen zurück, die der Empfänger bei der Anmeldung spezifiziert hat
getReceiveOptions in interface ReceivingSubscriptionpublic void sendDataTelegram(ApplicationDataTelegram applicationDataTelegram)
ReceivingSubscriptionSendet Daten an den Empfänger
sendDataTelegram in interface ReceivingSubscriptionapplicationDataTelegram - Telegrammpublic ReceiverState getState()
ReceivingSubscriptionGibt den Status des Empfängers zurück
getState in interface ReceivingSubscriptionpublic void setState(ReceiverState receiverState, long centralTransmitterId)
ReceivingSubscriptionSetzt den Status des Empfängers
setState in interface ReceivingSubscriptionreceiverState - neuer Statuspublic void sendStateTelegram(ReceiverState receiverState)
sendStateTelegram in interface ReceivingSubscriptionpublic BaseSubscriptionInfo getBaseSubscriptionInfo()
SubscriptionGibt die Objekt-Attributgruppenverwendung-Simulationsvariante-Kombination zurück, auf die diese Anmeldung stattfindet
getBaseSubscriptionInfo in interface Subscriptionpublic boolean isAllowed()
SubscriptionGibt zurück, ob die Anmeldung von der lokalen Rechteprüfung erlaubt ist
isAllowed in interface Subscriptionpublic UserLogin getAuthenticationState()
SubscriptionGibt die Id des angemeldeten Benutzers zurück. Liefert das gleiche wie getCommunication().getRemoteUserId()
getAuthenticationState in interface Subscriptionpublic long getNodeId()
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)
getNodeId in interface Subscriptionpublic TransmitterCommunicationInterface getCommunication()
SubscriptionGibt die Schnittstelle zum Kommunikationspartner zurück, also z.B. eine T_A oder T_T-Verbindung
getCommunication in interface RemoteSubscriptiongetCommunication in interface Subscriptionpublic void setRemoteState(long mainTransmitterId,
ConnectionState state)
setRemoteState in interface RemoteCentralSubscriptionpublic ConnectionState getConnectionState()
SubscriptionGibt den Verbindungsstatus zum Kommunikationspartner zurück
getConnectionState in interface Subscriptionpublic void unsubscribe()
SubscriptionBeendet die Datenanmeldung, sendet eventuelle Abmeldetelegramme
unsubscribe in interface Subscriptionpublic java.lang.String toString()
toString in class java.lang.Object