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()
ArchiveNumQueriesResultgetMaximumArchiveQueriesPerApplication in interface ArchiveNumQueriesResultpublic int getCurrentlyUsedQueries()
ArchiveNumQueriesResultgetCurrentlyUsedQueries in interface ArchiveNumQueriesResultpublic int getRemainingQueries()
ArchiveNumQueriesResultgetRemainingQueries in interface ArchiveNumQueriesResultpublic boolean isRequestSuccessful()
throws InterruptedException
isRequestSuccessful in interface ArchiveQueryResultgetErrorMessage angezeigt werdenInterruptedException - Der Thread, der den Auftrag bearbeitet, wurde abgebrochenpublic String getErrorMessage() throws InterruptedException
getErrorMessage in interface ArchiveQueryResultInterruptedException - Der Thread, der den Auftrag bearbeitet, wurde abgebrochenpublic void sendRequestInfo()
private void sendData()
public void archiveResponse(Data data)
public ArchiveQueryID getArchiveRequestID()