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()