public class RequestNumQueries extends Object implements ArchiveNumQueriesResult
StreamedArchiveRequester
benutzt.Modifier and Type | Field and Description |
---|---|
private ArchiveQueryID |
_client |
private int |
_currentlyUsedQueries |
private static Debug |
_debug
DebugLogger für Debug-Ausgaben
|
private short |
_defaultSimulationVariant
Falls keine Simulationsvariante gesetzt wird, dann wird dieser default-Wert benutzt.
|
private String |
_errorMessage |
private boolean |
_lock
Diese Variable sperrt alle Anfrage, bis die Antwort des Archivsystems vorliegt.
|
private int |
_maxArchiveQueriesPerApplication |
private boolean |
_requestSuccessful
Diese Variable speichert, ob die Infoanfrage erfolgreich war.
|
private StreamedArchiveRequester |
_streamedArchiveRequester |
Constructor and Description |
---|
RequestNumQueries(ArchiveQueryID archiveRequestID,
StreamedArchiveRequester streamedArchiveRequester,
short defaultSimulationVariant) |
Modifier and Type | Method and Description |
---|---|
void |
archiveResponse(Data data)
Diese Methode wird aufgerufen, wenn die Antwort des Archivsystems empfangen wurde.
|
ArchiveQueryID |
getArchiveRequestID() |
int |
getCurrentlyUsedQueries()
Gibt die (aus Sicht des Archivsystems) aktuelle Anzahl der derzeit aktiven Archivanfragen dieser Applikation zurück.
|
String |
getErrorMessage()
Diese Methode liefert einen String mit der Fehlermeldung, die dazu geführt hat das die Informationsanfrage nicht
ausgeführt werden konnte.
|
int |
getMaximumArchiveQueriesPerApplication()
Gibt die im Archivsystem fest eingestellte maximale Anzahl an gleichzeitigen Archivanfragen pro Applikation zurück.
|
int |
getRemainingQueries()
Gibt die (aus Sicht des Archivsystems) aktuelle Anzahl der noch möglichen gleichzeitigen Archivanfragen dieser Applikation zurück.
|
boolean |
isRequestSuccessful()
Diese Methode ist blockierend, bis die Antwort des Archivs vorliegt.
|
private void |
sendData() |
void |
sendRequestInfo()
Diese Methode verschickt eine Archivinfoanfrage an das entsprechende Archivsystem und meldet sich wieder als Sender
ab.
|
private final ArchiveQueryID _client
private static final Debug _debug
private String _errorMessage
private boolean _lock
private boolean _requestSuccessful
private final StreamedArchiveRequester _streamedArchiveRequester
private final short _defaultSimulationVariant
private int _maxArchiveQueriesPerApplication
private int _currentlyUsedQueries
public RequestNumQueries(ArchiveQueryID archiveRequestID, StreamedArchiveRequester streamedArchiveRequester, short defaultSimulationVariant)
public int getMaximumArchiveQueriesPerApplication()
ArchiveNumQueriesResult
getMaximumArchiveQueriesPerApplication
in interface ArchiveNumQueriesResult
public int getCurrentlyUsedQueries()
ArchiveNumQueriesResult
getCurrentlyUsedQueries
in interface ArchiveNumQueriesResult
public int getRemainingQueries()
ArchiveNumQueriesResult
getRemainingQueries
in interface ArchiveNumQueriesResult
public boolean isRequestSuccessful() throws InterruptedException
isRequestSuccessful
in interface ArchiveQueryResult
getErrorMessage
angezeigt werdenInterruptedException
- Der Thread, der den Auftrag bearbeitet, wurde abgebrochenpublic String getErrorMessage() throws InterruptedException
getErrorMessage
in interface ArchiveQueryResult
InterruptedException
- Der Thread, der den Auftrag bearbeitet, wurde abgebrochenpublic void sendRequestInfo()
private void sendData()
public void archiveResponse(Data data)
public ArchiveQueryID getArchiveRequestID()