private final class SubscriptionArchiveOnlineDataManager.Receiver extends Object implements ClientReceiverInterface
Modifier and Type | Field and Description |
---|---|
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 and Description |
---|
SubscriptionArchiveOnlineDataManager.Receiver(ArchiveRequestManager archive,
ClientDavInterface connection,
DatasetReceiverInterface receiverArchiveOnlineStream,
SystemObject systemObject,
DataDescription dataDescription,
ReceiveOptions receiveOptions,
HistoryTypeParameter historyType,
long history) |
Modifier and Type | Method and Description |
---|---|
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.
|
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
public SubscriptionArchiveOnlineDataManager.Receiver(ArchiveRequestManager archive, ClientDavInterface connection, DatasetReceiverInterface receiverArchiveOnlineStream, SystemObject systemObject, DataDescription dataDescription, ReceiveOptions receiveOptions, HistoryTypeParameter historyType, long history)
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()