class OnlineDataReferenceReceiverObject extends OnlineDataReceiverObject
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
OnlineDataReferenceReceiverObject.GetRefThread |
| Modifier and Type | Field and Description |
|---|---|
private OnlineDataReferenceReceiverObject.GetRefThread |
collectorThread
Thread der die Referenzdaten einholt
|
private ClientDavInterface |
dav
Verbindung zum Datenverteiler
|
private ReferenceQualifier |
qualifier
Qualifizierung der Referenz
|
private ReceiveOptions |
receiveOptions
Zeigt an auf welche Daten angemeldet werden soll.
|
receivedData, receivedTotal| Constructor and Description |
|---|
OnlineDataReferenceReceiverObject(ClientDavInterface dav,
ReceiveOptions receiveOptions,
OnlineDataReceiverSet receiverSet,
ReferenceQualifier qualifier,
NewDataCollector newDataCollector) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
getData(ResultData result)
Speichert den eingegangenen Datensatz.
|
private static SystemObject |
getReference(AttributeIdentifier attributeIdentifier,
ResultData resultData)
Holt eine Refernz aus einem Datensatz.
|
private ResultData |
takeReference(ReferenceQualifier reference,
SystemObject object,
long dataTime)
Holt die Referenz vom Datenverteiler
|
void |
unsubscribe(java.lang.Object object)
Meldet den Empfang von Daten ab.
|
dataAvailable, registerNewSubscriber, storeData, subscribe, take, updateprivate ReferenceQualifier qualifier
private ClientDavInterface dav
private ReceiveOptions receiveOptions
private OnlineDataReferenceReceiverObject.GetRefThread collectorThread
public OnlineDataReferenceReceiverObject(ClientDavInterface dav, ReceiveOptions receiveOptions, OnlineDataReceiverSet receiverSet, ReferenceQualifier qualifier, NewDataCollector newDataCollector)
dav - Verbindung zum DatenverteilerreceiveOptions - Empfangsoptionenqualifier - Datenidentifikation auf die sich der Receiver anmelden soll.receiverSet - Empfängergruppe, zu der dieser Empfänger gehört.newDataCollector - Objekt das benachrichtig wird, wenn neue Daten vorliegenprotected void getData(ResultData result)
OnlineDataReceiverObject.update(ResultData[]) aufgerufen wird, muss ein neuer
Thread gestartet werden, wenn eine Referenz abgeholt wird - sonst meldet der Dav keine weiteren Daten mehr.private ResultData takeReference(ReferenceQualifier reference, SystemObject object, long dataTime) throws FailureException
reference - Datenidentifikation, die benötigt wird. (Das Objekt reference.object) wird nicht verwendet!object - Objekt, für das die Daten abgerufen werden sollen.dataTime - Zeitstempel des ursprünglichen DatensatzesFailureException - Fehler beim Datenempfangpublic void unsubscribe(java.lang.Object object)
OnlineDataReceiverObjectunsubscribe in class OnlineDataReceiverObjectobject - private static SystemObject getReference(AttributeIdentifier attributeIdentifier, ResultData resultData) throws FailureException
attributeIdentifier - Attribut (bzw. Attributkette) hinter der der Referenzwert liegtresultData - Daten.FailureException - Fehler beim auslesen der Referenz.