|
||||||||||
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 KonfigurationMethod 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 |