public class RequestReceiver<T>
extends java.lang.Object
| Constructor and Description |
|---|
RequestReceiver(long timeoutDuration,
java.util.concurrent.TimeUnit unit)
Erstellt einen neuen RequestReceiver.
|
| Modifier and Type | Method and Description |
|---|---|
void |
answerReceived(int requestIndex,
T answer)
Wird aufgerufen, wenn eine Konfigurationsantwort eingegangen ist.
|
T |
getAnswer(int requestIndex)
Holt eine bereits eingegangene Konfigurationsantwort ab, oder wartet maximal
timeoutDuration, bis diese noch
ankommt. |
long |
getTimeoutDuration()
Timeout für den Empfang einer Konfigurationsantwort.
|
java.util.concurrent.TimeUnit |
getTimeoutUnit()
Gibt die Einheit von
TimeoutDuration zurück. |
public RequestReceiver(long timeoutDuration,
java.util.concurrent.TimeUnit unit)
timeoutDuration - Timeout für den Empfang einer Konfigurationsantwort. Wenn diese Dauer (in _timeoutUnit) überschritten wird, wird davon
Ausgegangen dass keine Antwort mehr erfolgt.unit - definiert die Einheit für timeoutDuration.public T getAnswer(int requestIndex) throws RequestException
timeoutDuration, bis diese noch
ankommt.requestIndex - RequestIndex der Nachricht, auf die gewartet werden soll.RequestException - Wenn die Konfiguration nicht innerhalb des Zeitlimits eine gültige Antwort geschickt hat.public void answerReceived(int requestIndex,
T answer)
getAnswer(int)-Aufruf die hier übergebene Nachricht zurückgibt.requestIndex - Request-Index der hier übergebenen Nachrichtanswer - Eigentliche Nachrichtpublic long getTimeoutDuration()
public java.util.concurrent.TimeUnit getTimeoutUnit()
TimeoutDuration zurück.getTimeoutDuration()