de.bsvrz.dav.daf.main.impl.archive.request
Class Query.DirectorStreamDemultiplexer

java.lang.Object
  extended by de.bsvrz.dav.daf.main.impl.archive.request.Query.DirectorStreamDemultiplexer
All Implemented Interfaces:
StreamDemultiplexerDirector
Enclosing class:
Query

private static class Query.DirectorStreamDemultiplexer
extends Object
implements StreamDemultiplexerDirector


Field Summary
private  ArchiveQueryID _archiveQueryID
           
private  StreamedArchiveRequester _streamedArchiveRequester
          Dieses Objekt wird benötigt um ihm das Ticket zu überreichen, dies wird dann verpackt und verschickt.
 
Constructor Summary
Query.DirectorStreamDemultiplexer(ArchiveQueryID archiveQueryID, StreamedArchiveRequester streamedArchiveRequester)
          Implementiert den StreamDemultiplexerDirector, somit kann eine Archivanfrage einen StreamDemultiplexer erzeugen.
 
Method Summary
 void sendNewTicketIndexToSender(byte[] streamTicketPacket)
          Diese Methode schickt einem StreamMultiplexer ein streamTicketPaket(Byte-Array), dieses wird mit dem Methodenaufruf StreamMultiplexer#setMaximumStreamTicketIndexForStream an den StreamMultiplexer übergeben.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_streamedArchiveRequester

private final StreamedArchiveRequester _streamedArchiveRequester
Dieses Objekt wird benötigt um ihm das Ticket zu überreichen, dies wird dann verpackt und verschickt.


_archiveQueryID

private final ArchiveQueryID _archiveQueryID
Constructor Detail

Query.DirectorStreamDemultiplexer

public Query.DirectorStreamDemultiplexer(ArchiveQueryID archiveQueryID,
                                         StreamedArchiveRequester streamedArchiveRequester)
Implementiert den StreamDemultiplexerDirector, somit kann eine Archivanfrage einen StreamDemultiplexer erzeugen.

Parameters:
streamedArchiveRequester - Verpackt und verschickt das Ticket an das Archiv
archiveQueryID - Welche Archivanfrage verschickt das Ticket
Method Detail

sendNewTicketIndexToSender

public void sendNewTicketIndexToSender(byte[] streamTicketPacket)
Description copied from interface: de.bsvrz.sys.funclib.communicationStreams.StreamDemultiplexerDirector
Diese Methode schickt einem StreamMultiplexer ein streamTicketPaket(Byte-Array), dieses wird mit dem Methodenaufruf StreamMultiplexer#setMaximumStreamTicketIndexForStream an den StreamMultiplexer übergeben. Das Paket enthält den Index eines Streams und den neuen Index bis zu dem der Stream streamDataPackets verschicken darf. Beide Informationen werden vom StreamDemultiplexer in einem Byte-Array kodiert. Die Methode wird in einem StreamDemultilexer aufgerufen, wenn die gespeicherten Nutzdatenpakete eine gewisse Marke unterschreiten. Dadurch erhält der StreamMultiplexer die Erlaubnis weiter Nutdatenpakete zu verschicken.

Specified by:
sendNewTicketIndexToSender in interface StreamDemultiplexerDirector
Parameters:
streamTicketPacket - Dieses Paket wird vom StreamDemultiplexer zum StreamMultiplexer geschickt. Es hat den Index des Stream und den neuen maximalen Index, bis zu dem der StreamMultiplexer Pakete verschicken kann, als Inhalt.