|
|||||||||
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.SubscriptionArchiveOnlineDataManager.Receiver
private final class SubscriptionArchiveOnlineDataManager.Receiver
Objekt, das Onlinedaten puffert oder durchreicht, es stellt ebenfalls den ersten Online verfügbaren Datensatz zur Verfügung. Es enthält alle Informationen, die nötig sind, um ein anderes Objekt Archivanfragen stellen zu lassen. Es stellt ein Synchronisationsobjekt zur Verfügung, auf dem sich ein anderes Objekt synchronisieren kann.
Field Summary | |
---|---|
private ArchiveRequestManager |
_archive
Objekt, über das Archivanfragen gestellt werden können. |
private SubscriptionArchiveOnlineDataManager.ArchiveDataRequester |
_archiveThread
Thread, der die Archivdaten anfordert und vor die Onlinedaten mischt |
private ClientDavInterface |
_connection
TBD wird benötigt, wenn es nur begrentzt viele Thread geben soll Wird zum an/abmelden der Datenidentifikationen benötigt |
private DataDescription |
_dataDescription
Wird für die Archivanfrage gebraucht |
private Object |
_dataReceived
Objekt, auf das synchronisiert wird sobald Daten empfangen werden. |
private ResultData |
_firstOnlineDataSet
Speichert den ersten online Datensatz, dieser wird gebraucht, um den Endzeitpunkt der Archivanfrage zu bestimmen |
private boolean |
_handOverOnline
Können die online empfangenen Daten direkt durchgereicht werden? Das ist möglich, wenn die Archivdaten alle übertragen wurden und der Puffer, der die online Daten speichert, leer ist. |
private long |
_history
Zeitbereich oder Index, der aus dem aus Archivsystem angefordert werden soll. |
private HistoryTypeParameter |
_historyType
bezieht sich der Wert in der Variablen _history auf einen Zeitbereich oder einen Datenindex |
private List<ResultData[]> |
_onlineBuffer
Puffert online Daten während Archivdaten angefordert werden. |
private boolean |
_receivedFirstOnlineDataSet
Wurde der erste online Datensatz empfangen |
private ReceiveOptions |
_receiveOptions
Wird benötigt um zu entscheiden ob die Archidaten delta oder normal sein sollen |
private DatasetReceiverInterface |
_receiverArchiveOnlineStream
Empfänger, der die gemischten Archin/Onlinedaten haben möchte. |
private SystemObject |
_systemObject
Wird für die Archivanfrage gebraucht |
private boolean |
_unsubcribeReceiver
Diese Variable wird true, wenn der Sender abgemeldet wurde. |
Constructor Summary | |
---|---|
SubscriptionArchiveOnlineDataManager.Receiver(ArchiveRequestManager archive,
ClientDavInterface connection,
DatasetReceiverInterface receiverArchiveOnlineStream,
SystemObject systemObject,
DataDescription dataDescription,
ReceiveOptions receiveOptions,
HistoryTypeParameter historyType,
long history)
|
Method Summary | |
---|---|
private Object |
getDataReceived()
|
private ResultData |
getFirstOnlineDataSet()
|
private boolean |
isReceivedFirstOnlineDataSet()
|
void |
sendData(Dataset[] datasetResult)
Verschickt Datensätze an den Vorgegebenen Empfänger, falls dieser die Verbindung noch nicht abgemeldet hat. |
private void |
sendOnlineBuffer()
Diese Methode wird aufgerufen, sobald alle Archivdaten vor den Onlinestrom gemischt wurden. |
void |
unsubscribeReceiver()
Diese Methode wird aufgerufen, wenn der Empfänger abgemeldet wird. |
void |
update(ResultData[] results)
Aktualisierungsmethode, die nach Empfang eines angemeldeten Datensatzes von den Datenverteiler-Applikationsfunktionen aufgerufen wird. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private final ArchiveRequestManager _archive
private final ClientDavInterface _connection
private final List<ResultData[]> _onlineBuffer
private final DatasetReceiverInterface _receiverArchiveOnlineStream
private final ReceiveOptions _receiveOptions
private final HistoryTypeParameter _historyType
private long _history
private final Object _dataReceived
private boolean _receivedFirstOnlineDataSet
private boolean _handOverOnline
private ResultData _firstOnlineDataSet
private final SystemObject _systemObject
private final DataDescription _dataDescription
private boolean _unsubcribeReceiver
private final SubscriptionArchiveOnlineDataManager.ArchiveDataRequester _archiveThread
Constructor Detail |
---|
public SubscriptionArchiveOnlineDataManager.Receiver(ArchiveRequestManager archive, ClientDavInterface connection, DatasetReceiverInterface receiverArchiveOnlineStream, SystemObject systemObject, DataDescription dataDescription, ReceiveOptions receiveOptions, HistoryTypeParameter historyType, long history)
Method Detail |
---|
public void update(ResultData[] results)
ClientReceiverInterface
update
in interface ClientReceiverInterface
results
- Feld mit den empfangenen Ergebnisdatensätzen.public void unsubscribeReceiver()
private Object getDataReceived()
private boolean isReceivedFirstOnlineDataSet()
private ResultData getFirstOnlineDataSet()
public void sendData(Dataset[] datasetResult)
datasetResult
- Archivdaten oder ResultData, die verschickt werden sollenprivate void sendOnlineBuffer()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |