public class ArchiveStreamCombiner extends Object implements ArchiveDataQueryResult
| Modifier and Type | Class and Description |
|---|---|
private static class |
ArchiveStreamCombiner.CombinedStream |
private static class |
ArchiveStreamCombiner.RelativeCombinedStream |
| Modifier and Type | Field and Description |
|---|---|
private List<Integer> |
_numStreamsToCombine |
private List<ArchiveDataSpecification> |
_originalSpecs |
private ArchiveDataQueryResult |
_rawResult |
| Constructor and Description |
|---|
ArchiveStreamCombiner() |
| Modifier and Type | Method and Description |
|---|---|
void |
addQuery(int size,
ArchiveDataSpecification spec)
Wird mehrmals aufgerufen.
|
private ArchiveDataStream[] |
combineStreams(ArchiveDataStream[] streams) |
String |
getErrorMessage()
Bestimmt eine Fehlernachricht, falls die entsprechende Archivanfrage nicht erfolgreich war.
|
ArchiveDataStream[] |
getStreams()
Bestimmt die Ergebnisdatenströme der entsprechenden Archivdatenspezifikationen aus der Archivanfrage.
|
boolean |
isRequestSuccessful()
Bestimmt, ob die Archivanfrage erfolgreich war.
|
void |
setRawResult(ArchiveDataQueryResult rawResult) |
private ArchiveDataQueryResult _rawResult
private List<ArchiveDataSpecification> _originalSpecs
public ArchiveDataStream[] getStreams() throws InterruptedException, IllegalStateException
ArchiveDataQueryResultgetStreams in interface ArchiveDataQueryResultInterruptedException - Falls der aufrufende Thread unterbrochen wurde, während auf die entsprechende
Antwortnachricht aus dem Archivsystem gewartet wurde.IllegalStateException - Falls die Archivanfrage nicht erfolgreich war und keine Ergebnisdatenströme bestimmt
werden können.ArchiveRequestManager.request(ArchiveQueryPriority,ArchiveDataSpecification),
ArchiveRequestManager.request(ArchiveQueryPriority, java.util.List)private ArchiveDataStream[] combineStreams(ArchiveDataStream[] streams)
public boolean isRequestSuccessful()
throws InterruptedException
ArchiveQueryResultArchiveQueryResult.getErrorMessage() abgerufen werden kann.isRequestSuccessful in interface ArchiveQueryResulttrue, falls die Anfrage erfolgreich war, sonst false.InterruptedException - Falls der aufrufende Thread unterbrochen wurde, während auf die entsprechende
Antwortnachricht aus dem Archivsystem gewartet wurde.public String getErrorMessage() throws InterruptedException
ArchiveQueryResultgetErrorMessage in interface ArchiveQueryResultInterruptedException - Falls der aufrufende Thread unterbrochen wurde, während auf die entsprechende
Antwortnachricht aus dem Archivsystem gewartet wurde.public void setRawResult(ArchiveDataQueryResult rawResult)
public void addQuery(int size,
ArchiveDataSpecification spec)
size - Anzahl zu bündelnder Streams, bei Anfragen ohne Pid 1spec - Originale Anfrage