public class ReceiverSubscription
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private ClientReceiverInterface |
_clientReceiver
Representant der Empänger
|
private CollectingReceiver |
_collectingReceiver
Objekt, dass für die Zwischenspeicherung und Auslieferung von empfangenen Datensätzen an den Receiver zuständig ist, oder
null , falls noch nicht angemeldet. |
private DataDescription |
_dataDescription
Beschreibende Informationen der zu versendenden Daten
|
private ReceiveSubscriptionInfo |
_receiveSubscriptionInfo
Empfangsanmeldeinformationen
|
private SystemObject |
_systemObject
Der Objekt dieser Anmeldung
|
private long |
_timeInCache
Die mindestens Verweilzeit im Cache wenn -1 dann 60000
|
Constructor and Description |
---|
ReceiverSubscription(ClientReceiverInterface client,
SystemObject systemObject,
DataDescription dataDescription,
short externalSimulationVariant,
ReceiveOptions options,
ReceiverRole role,
long timeInCache)
Erzeugt ein neues Objekt mit den gegebenen Parametern.
|
Modifier and Type | Method and Description |
---|---|
BaseSubscriptionInfo |
getBaseSubscriptionInfo()
Gibt die Basisanmeldeinformationen zurück.
|
ClientReceiverInterface |
getClientReceiver()
Gibt den Empfänger zurück.
|
CollectingReceiver |
getCollectingReceiver()
Bestimmt des Objekt, dass für die Zwischenspeicherung und Auslieferung von empfangenen Datensätzen an den Receiver zuständig ist.
|
DataDescription |
getDataDescription()
Gibt die beschreibende Informationen der zu versendenden Daten zurück.
|
boolean |
getDelayedDataFlag()
Gibt an, ob Interesse an nachgelieferten oder an aktuellen Datensätzen besteht.
|
boolean |
getDeltaDataFlag()
Gibt an, ob Interesse an nur den geänderten Datensätzen oder an allen Datensätzen besteht.
|
ReceiveSubscriptionInfo |
getReceiveSubscriptionInfo()
Gibt die Empfangsanmeldeinformationen zurück.
|
SystemObject |
getSystemObject()
Gibt das Systemobjekt zurück.
|
long |
getTimeInCache()
Gibt die Mindestverweilzeit im Cache zurück.
|
boolean |
isDrain()
Gibt an, ob die Applikation als Senke für dieses Datums angemeldet ist oder nicht.
|
boolean |
isReceiver()
Gibt an, ob die Applikation als ein normaler Empfänger für dieses Datums angemeldet ist oder nicht.
|
void |
setCollectingReceiver(CollectingReceiver collectingReceiver)
Setzt des Objekt, dass für die Zwischenspeicherung und Auslieferung von empfangenen Datensätzen an den Receiver zuständig ist.
|
boolean |
updateSubscriptionInfo(ReceiveSubscriptionInfo _receiveSubscriptionInfo)
Aktualisiert die Empfangsanmeldeinformationen.
|
private ClientReceiverInterface _clientReceiver
Representant der Empänger
private SystemObject _systemObject
Der Objekt dieser Anmeldung
private DataDescription _dataDescription
Beschreibende Informationen der zu versendenden Daten
private ReceiveSubscriptionInfo _receiveSubscriptionInfo
Empfangsanmeldeinformationen
private long _timeInCache
Die mindestens Verweilzeit im Cache wenn -1 dann 60000
private CollectingReceiver _collectingReceiver
Objekt, dass für die Zwischenspeicherung und Auslieferung von empfangenen Datensätzen an den Receiver zuständig ist, oder null
, falls noch nicht angemeldet.
public ReceiverSubscription(ClientReceiverInterface client, SystemObject systemObject, DataDescription dataDescription, short externalSimulationVariant, ReceiveOptions options, ReceiverRole role, long timeInCache)
Erzeugt ein neues Objekt mit den gegebenen Parametern.
client
- EmpfängersystemObject
- Objekt der AnmeldungdataDescription
- Informationen zur Beschreibung der AnmeldungexternalSimulationVariant
- Simulationsvarianteoptions
- Optionenrole
- RolletimeInCache
- mindestverweilzeit im Cachepublic final ClientReceiverInterface getClientReceiver()
Gibt den Empfänger zurück.
public final SystemObject getSystemObject()
Gibt das Systemobjekt zurück.
public final DataDescription getDataDescription()
Gibt die beschreibende Informationen der zu versendenden Daten zurück.
public final boolean getDelayedDataFlag()
Gibt an, ob Interesse an nachgelieferten oder an aktuellen Datensätzen besteht.
true:
nachgelieferte Datensätze erwünscht, false:
nachgelieferte Datensätze nicht erwünschtpublic final boolean getDeltaDataFlag()
Gibt an, ob Interesse an nur den geänderten Datensätzen oder an allen Datensätzen besteht.
true:
nur geänderte Datensätze erwünscht, false:
alle Datensätze erwünschtpublic final boolean isReceiver()
Gibt an, ob die Applikation als ein normaler Empfänger für dieses Datums angemeldet ist oder nicht.
true:
Applikation ist normaler Emfänger, false:
Applikation ist kein normaler Empfängerpublic final boolean isDrain()
Gibt an, ob die Applikation als Senke für dieses Datums angemeldet ist oder nicht.
true:
Applikation ist als Senke angemeldet, false:
Applikation ist nicht als Senke angemeldet.public final long getTimeInCache()
Gibt die Mindestverweilzeit im Cache zurück.
public final ReceiveSubscriptionInfo getReceiveSubscriptionInfo()
Gibt die Empfangsanmeldeinformationen zurück.
public final BaseSubscriptionInfo getBaseSubscriptionInfo()
Gibt die Basisanmeldeinformationen zurück.
public final boolean updateSubscriptionInfo(ReceiveSubscriptionInfo _receiveSubscriptionInfo)
Aktualisiert die Empfangsanmeldeinformationen.
_receiveSubscriptionInfo
- Empfangsanmeldeinformationentrue:
Empfangsanmeldeinformationen aktualisiert, false:
Empfangsanmeldeinformationen nicht aktualisiertpublic void setCollectingReceiver(CollectingReceiver collectingReceiver)
Setzt des Objekt, dass für die Zwischenspeicherung und Auslieferung von empfangenen Datensätzen an den Receiver zuständig ist.
collectingReceiver
- Objekt, dass für die Zwischenspeicherung und Auslieferung von empfangenen Datensätzen an den Receiver zuständig ist.public CollectingReceiver getCollectingReceiver()
Bestimmt des Objekt, dass für die Zwischenspeicherung und Auslieferung von empfangenen Datensätzen an den Receiver zuständig ist.
null
, falls noch nicht angemeldet.