public class LocalReceivingSubscription extends Object implements LocalSubscription, ReceivingSubscription
| Constructor and Description |
|---|
LocalReceivingSubscription(SubscriptionsManager subscriptionsManager,
BaseSubscriptionInfo baseSubscriptionInfo,
boolean drain,
ReceiveOptions receiveOptions,
ApplicationCommunicationInterface applicationConnection) |
| Modifier and Type | Method and Description |
|---|---|
BaseSubscriptionInfo |
getBaseSubscriptionInfo()
Gibt die Objekt-Attributgruppenverwendung-Simulationsvariante-Kombination zurück, auf die diese Anmeldung stattfindet
|
long |
getCentralDistributorId()
Gibt die Zentraldatenverteiler-ID zurück.
|
ApplicationCommunicationInterface |
getCommunication()
Gibt die Schnittstelle zum Kommunikationspartner zurück, also z.B.
|
ConnectionState |
getConnectionState()
Gibt den Verbindungsstatus zum Kommunikationspartner zurück
|
long |
getNodeId()
Liefert die Id der anmeldenden Applikation bzw.
|
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
|
long |
getUserId()
Gibt die Id des angemeldeten Benutzers 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 |
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 |
setState(ReceiverState receiverState,
long centralTransmitterId)
Setzt den Status des Empfängers
|
String |
toString() |
void |
unsubscribe()
Beendet die Datenanmeldung, sendet eventuelle Abmeldetelegramme
|
public LocalReceivingSubscription(SubscriptionsManager subscriptionsManager, BaseSubscriptionInfo baseSubscriptionInfo, boolean drain, ReceiveOptions receiveOptions, ApplicationCommunicationInterface applicationConnection)
public long getNodeId()
SubscriptiongetNodeId in interface Subscriptionpublic ConnectionState getConnectionState()
SubscriptiongetConnectionState in interface Subscriptionpublic long getCentralDistributorId()
SubscriptiongetCentralDistributorId in interface Subscriptionpublic void unsubscribe()
Subscriptionunsubscribe in interface Subscriptionpublic ApplicationCommunicationInterface getCommunication()
SubscriptiongetCommunication in interface LocalSubscriptiongetCommunication in interface Subscriptionpublic boolean isDrain()
ReceivingSubscriptionisDrain in interface ReceivingSubscriptionpublic ReceiveOptions getReceiveOptions()
ReceivingSubscriptiongetReceiveOptions in interface ReceivingSubscriptionpublic void sendDataTelegram(ApplicationDataTelegram applicationDataTelegram)
ReceivingSubscriptionsendDataTelegram in interface ReceivingSubscriptionapplicationDataTelegram - Telegrammpublic ReceiverState getState()
ReceivingSubscriptiongetState in interface ReceivingSubscriptionpublic void setState(ReceiverState receiverState, long centralTransmitterId)
ReceivingSubscriptionsetState in interface ReceivingSubscriptionreceiverState - neuer Statuspublic void sendStateTelegram(ReceiverState receiverState)
sendStateTelegram in interface ReceivingSubscriptionreceiverState - Empfängerstatuspublic BaseSubscriptionInfo getBaseSubscriptionInfo()
SubscriptiongetBaseSubscriptionInfo in interface Subscriptionpublic boolean isAllowed()
SubscriptionisAllowed in interface Subscriptionpublic long getUserId()
SubscriptiongetUserId in interface Subscription