public class RemoteReceiverSubscription extends java.lang.Object implements RemoteReceivingSubscription
Anmeldung eines entfernten Empfängers auf diesen Datenverteiler (der möglicherweise Zentraldatenverteiler ist)
Modifier and Type | Field and Description |
---|---|
private BaseSubscriptionInfo |
_baseSubscriptionInfo |
private DataState |
_lastSendDataState |
private ConnectionState |
_lastSendState |
private java.util.Set<java.lang.Long> |
_potentialCentralDistributors |
private ReceiverState |
_receiverState |
private SubscriptionsManager |
_subscriptionsManager |
private TransmitterCommunicationInterface |
_transmitterCommunication |
Constructor and Description |
---|
RemoteReceiverSubscription(SubscriptionsManager subscriptionsManager,
TransmitterCommunicationInterface transmitterCommunication,
BaseSubscriptionInfo baseSubscriptionInfo,
java.util.Collection<java.lang.Long> transmitterIds) |
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)
Sendet an einen Empfänger falls nötig im Falle eines geänderten Anmeldestatus einen leeren Datensatz mit dem entsprechenden Inhalt.
|
void |
setPotentialDistributors(java.util.Collection<java.lang.Long> value) |
void |
setState(ReceiverState receiverState,
long centralTransmitterId)
Setzt den Status des Empfängers
|
java.lang.String |
toString() |
void |
unsubscribe()
Beendet die Datenanmeldung, sendet eventuelle Abmeldetelegramme
|
private final SubscriptionsManager _subscriptionsManager
private final TransmitterCommunicationInterface _transmitterCommunication
private final BaseSubscriptionInfo _baseSubscriptionInfo
private final java.util.Set<java.lang.Long> _potentialCentralDistributors
private ReceiverState _receiverState
private ConnectionState _lastSendState
private DataState _lastSendDataState
public RemoteReceiverSubscription(SubscriptionsManager subscriptionsManager, TransmitterCommunicationInterface transmitterCommunication, BaseSubscriptionInfo baseSubscriptionInfo, java.util.Collection<java.lang.Long> transmitterIds)
public boolean isDrain()
ReceivingSubscription
Gibt true zurück, wenn es sich um eine Senke handelt
isDrain
in interface ReceivingSubscription
public ReceiveOptions getReceiveOptions()
ReceivingSubscription
Gibt die Empfangsoptionen zurück, die der Empfänger bei der Anmeldung spezifiziert hat
getReceiveOptions
in interface ReceivingSubscription
public void sendDataTelegram(ApplicationDataTelegram applicationDataTelegram)
ReceivingSubscription
Sendet Daten an den Empfänger
sendDataTelegram
in interface ReceivingSubscription
applicationDataTelegram
- Telegrammpublic ReceiverState getState()
ReceivingSubscription
Gibt den Status des Empfängers zurück
getState
in interface ReceivingSubscription
public void setState(ReceiverState receiverState, long centralTransmitterId)
ReceivingSubscription
Setzt den Status des Empfängers
setState
in interface ReceivingSubscription
receiverState
- neuer Statuspublic 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.
sendStateTelegram
in interface ReceivingSubscription
receiverState
- Empfängerstatuspublic void unsubscribe()
Subscription
Beendet die Datenanmeldung, sendet eventuelle Abmeldetelegramme
unsubscribe
in interface Subscription
public BaseSubscriptionInfo getBaseSubscriptionInfo()
Subscription
Gibt die Objekt-Attributgruppenverwendung-Simulationsvariante-Kombination zurück, auf die diese Anmeldung stattfindet
getBaseSubscriptionInfo
in interface Subscription
public boolean isAllowed()
Subscription
Gibt zurück, ob die Anmeldung von der lokalen Rechteprüfung erlaubt ist
isAllowed
in interface Subscription
public UserLogin getAuthenticationState()
Subscription
Gibt die Id des angemeldeten Benutzers zurück. Liefert das gleiche wie getCommunication().getRemoteUserId()
getAuthenticationState
in interface Subscription
public long getNodeId()
Subscription
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)
getNodeId
in interface Subscription
public ConnectionState getConnectionState()
Subscription
Gibt den Verbindungsstatus zum Kommunikationspartner zurück
getConnectionState
in interface Subscription
public long getCentralDistributorId()
Subscription
Gibt die Zentraldatenverteiler-ID zurück. Nur sinnvoll bei Quelle/Senke-Anmeldungen. Ist der Zentraldatenverteiler unbekannt, wird -1 zurückgegeben.
getCentralDistributorId
in interface Subscription
public TransmitterCommunicationInterface getCommunication()
Subscription
Gibt die Schnittstelle zum Kommunikationspartner zurück, also z.B. eine T_A oder T_T-Verbindung
getCommunication
in interface RemoteSubscription
getCommunication
in interface Subscription
public java.lang.String toString()
toString
in class java.lang.Object
public java.util.Set<java.lang.Long> getPotentialDistributors()
getPotentialDistributors
in interface RemoteSubscription
public void setPotentialDistributors(java.util.Collection<java.lang.Long> value)
setPotentialDistributors
in interface RemoteSubscription
public void addPotentialDistributor(long transmitterId)
addPotentialDistributor
in interface RemoteSubscription
public void removePotentialDistributor(long transmitterId)
removePotentialDistributor
in interface RemoteSubscription