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, update
private 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)
OnlineDataReceiverObject
unsubscribe
in class OnlineDataReceiverObject
object
- 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.