|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectde.bsvrz.pua.prot.client.AnswerReceiver
public abstract class AnswerReceiver
Klasse die den Empfang von Daten über den Datenverteiler übernimmt. Eingehende Daten werden nur gespeichert, wenn diese einen Datenteil haben. Außerdem müssen Anfrage-Id und Sender mit den im Konstruktor übergebenen Objekten übereinstimmen.
| Field Summary | |
|---|---|
protected DataDescription |
dataDescription
Angemeldete Atg und Aspekt. |
protected ClientDavInterface |
dav
Verbindung zum Datenverteiler. |
protected static Debug |
debug
Debug Ausgabe |
protected RingBuffer<ResultData> |
incoming
Eingegangene Daten |
protected SystemObject |
object
Skriptobjekt, auf das sich die Antwort bezieht. |
protected SystemObject |
receiver
Objekt das die Anfrage, auf die sich diese Antwort bezieht, gesendet hat. |
protected long |
requestId
Anfrage-Id. |
| Constructor Summary | |
|---|---|
AnswerReceiver(ClientDavInterface dav,
SystemObject object,
java.lang.String atg,
java.lang.String asp,
SystemObject receiver,
long requestId,
ReceiverRole role,
long timeout)
Erzeugt den Empfänger. |
|
| Method Summary | |
|---|---|
boolean |
hasData()
Zeigt an, ob Antwortdaten vorliegen. |
ResultData |
take()
Liefert einen Antwortdatensatz. |
ResultData |
take(long timeout)
Liefert einen Antwortdatensatz. |
boolean |
unsubscribe()
Meldet den Empfang von Daten ab. |
void |
update(ResultData[] results)
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected static final Debug debug
protected ClientDavInterface dav
protected SystemObject object
protected RingBuffer<ResultData> incoming
protected DataDescription dataDescription
protected long requestId
protected SystemObject receiver
| Constructor Detail |
|---|
public AnswerReceiver(ClientDavInterface dav,
SystemObject object,
java.lang.String atg,
java.lang.String asp,
SystemObject receiver,
long requestId,
ReceiverRole role,
long timeout)
throws ConfigurationException
dav - Verbindung zum Datenverteilerobject - Systemobjekt, dessen Daten empfangen werden sollenatg - Pid der Attributgruppe auf die sich der Empfänger anmeldet.asp - Pid des Aspekts auf den sich der Empfänger anmeldet.receiver - Objekt das als Absender im Datensatz eingetragen wist.requestId - Anfrage-Id.role - Empfänger oder Senke.timeout - Maximale Wartezeit, in der eine Antwort eingehen muss.
0 ist die unbegrenzte Wartezeit.
ConfigurationException - Fehler bei der Kommunikation mit der Konfiguration| Method Detail |
|---|
public boolean hasData()
public boolean unsubscribe()
public void update(ResultData[] results)
ClientReceiverInterface#update(ResultData[])
public ResultData take(long timeout)
throws java.lang.InterruptedException
timeout - Wartezeit. 0 bedeutet unbegrenzte Wartezeit.
java.lang.InterruptedException - Warten auf Antwortdatensatz wurde unterbrochen.
public ResultData take()
throws java.lang.InterruptedException
java.lang.InterruptedException - Warten auf Antwortdatensatz wurde unterbrochen.
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||