|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.dav.daf.main.impl.archive.request.DataStream
class DataStream
Diese Klasse implementiert das Interface ArchiveDataStream. Die Datensätze, die empfangen wurden, können gepackt
sein, diese Klasse entpackt die Datensätze und stellt sie als Objekte zur Verfügung. Diese Klasse wird von der Klasse
StreamedArchiveRequester
benutzt.
Field Summary | |
---|---|
private ArchiveDataSpecification |
_archiveDataSpecification
|
private static Debug |
_debug
DebugLogger für Debug-Ausgaben |
private int |
_indexOfStream
Stream von dem die Daten geholt werden. |
private Query |
_query
Dies ist die Anfrage, zu der dieser Stream gehört. |
private StreamDemultiplexer |
_streamDemultiplexer
|
Constructor Summary | |
---|---|
DataStream(int indexOfStream,
StreamDemultiplexer streamDemultiplexer,
ArchiveDataSpecification archiveDataSpecification,
Query query)
Objekt, dass einen Stream repräsentiert. |
Method Summary | |
---|---|
void |
abort()
Diese Methode wird aufgerufen, falls keine Datensätze mehr benötigt werden. |
ArchiveDataSpecification |
getDataSpecification()
Bestimmt die Archivdatenspezifikation, die zu diesem Ergebnisdatenstrom geführt hat. |
ArchiveData |
take()
Diese Methode stellt einen archivierten Datensatz zur Verfügung. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private final StreamDemultiplexer _streamDemultiplexer
private final int _indexOfStream
private final Query _query
private final ArchiveDataSpecification _archiveDataSpecification
private static final Debug _debug
Constructor Detail |
---|
public DataStream(int indexOfStream, StreamDemultiplexer streamDemultiplexer, ArchiveDataSpecification archiveDataSpecification, Query query)
indexOfStream
- Index des StreamsstreamDemultiplexer
- Objekt über das Datensätze angefordert werden könnenarchiveDataSpecification
- Siehe Klassenbeschreibungquery
- Archivanfrage, die zu diesem Objekt gehörtMethod Detail |
---|
public ArchiveDataSpecification getDataSpecification()
ArchiveDataStream
getDataSpecification
in interface ArchiveDataStream
public ArchiveData take() throws ClosedChannelException, InterruptedException, ProtocolException
take
in interface ArchiveDataStream
ClosedChannelException
- Die Verbindung zum DaV wurde unterbrochen
InterruptedException
- Der Thread, der sich um die Verwaltung des Datensatzempfangs kümmert wurde mit
Interrupt
abgebrochen
ProtocolException
- Ein Datensatz wurde entweder doppelt empfangen oder fehltpublic void abort()
abort
in interface ArchiveDataStream
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |