class ReferenceReceiver extends java.lang.Object implements ClientReceiverInterface
unsubscribe()
muss aufgerufen werden, nachdem die
Daten mit take(long)
abgerufen wurden.Modifier and Type | Field and Description |
---|---|
private DataDescription |
dataDescription |
private ClientDavInterface |
dav
Verbindung zum Datenverteiler
|
private SystemObject |
object |
private boolean |
receivedData
Zeigt an ob Daten vorliegen.
|
private ResultData |
resultData
Daten.
|
Constructor and Description |
---|
ReferenceReceiver(ClientDavInterface dav,
SystemObject systemObject,
AttributeGroup attributeGroup,
Aspect aspect,
ReceiveOptions options)
Meldet den Empfang von Daten an.
|
Modifier and Type | Method and Description |
---|---|
boolean |
hasData() |
ResultData |
take(long timeout)
Gibt den aktuellen Wert der Datenidentifikation zurück.
|
void |
unsubscribe()
Meldet den Empfang von Daten ab.
|
void |
update(ResultData[] results)
Wird verwendet um Daten von Referenzen vom Dav abzuholen.
|
private boolean receivedData
private ResultData resultData
private ClientDavInterface dav
private SystemObject object
private DataDescription dataDescription
public ReferenceReceiver(ClientDavInterface dav, SystemObject systemObject, AttributeGroup attributeGroup, Aspect aspect, ReceiveOptions options) throws FailureException
dav
- Verbindung zum Datenverteiler.systemObject
- Objekt.attributeGroup
- Attributgruppe.aspect
- Aspekt.options
- Datenart.FailureException
- Fehler beim Anmelden auf die Datenidentifikation.public void update(ResultData[] results)
update
in interface ClientReceiverInterface
results
- Feld mit den empfangenen Ergebnisdatensätzen.ClientReceiverInterface.update(ResultData[])
public void unsubscribe() throws FailureException
FailureException
- Fehler bei der Kommunikation mit der Konfigurationpublic ResultData take(long timeout) throws java.lang.InterruptedException
timeout
- Maximale Wartezeit.null
falls keine Daten innerhalb der Wartezeit vorliegen.java.lang.InterruptedException
- Warten auf Antwortdatensatz wurde unterbrochen.public boolean hasData()