|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.pua.prot.processing.onlinebuffer.OnlineDataReceiverSet
public class OnlineDataReceiverSet
Verwaltet Anmeldungen zum Abgreifen von Online-Daten. Alle vom Set erzeugten Empfänger haben den gleichen Zeitbereich und die gleichen Optionen (Normal oder Delta-Daten, nachgelieferte Daten). Es wird nur ein neuer Empfänger erzeugt, wenn es noch keinen Empfänger für die jeweilige Datenidentifikation gibt. Alle Empfänger werden als einfahce Empfänger erzeugt (nicht als Senke). Der OnlineDataReceiver erzeugt genau einen Empfänger je Datenidentifikation.
Constructor Summary | |
---|---|
OnlineDataReceiverSet(ClientDavInterface dav,
ReceiveOptions receiveOptions,
java.util.List<Tuple<java.lang.Long,java.lang.Long>> periodList,
NewDataCollector newDataCollector)
Erzeugt das Objekt. |
Method Summary | |
---|---|
OnlineDataReceiver |
createReceiver(Qualifier qualifier)
Gibt einen Empfänger für die übergebende Datenidentifikation zurück. |
boolean |
dataAvailable()
Zeigt ob Daten für einen der Empfänger vorliegen. |
protected ClientDavInterface |
getDav()
Liefert Verbindung zum Dav. |
protected java.util.List<Tuple<java.lang.Long,java.lang.Long>> |
getPeriods()
Liefert eine Liste mit Zeitbereichen. |
ReceiveOptions |
getReceiveOptions()
Liefert die Empfangsoptionen. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public OnlineDataReceiverSet(ClientDavInterface dav, ReceiveOptions receiveOptions, java.util.List<Tuple<java.lang.Long,java.lang.Long>> periodList, NewDataCollector newDataCollector) throws FailureException
dav
- Verbindung zum DatenverteilerreceiveOptions
- Anmeldeoptionen. (delta-Anfrage, nachgelieferte Daten). Siehe auch Klassenbeschreibung
für weitere Informationen.periodList
- Liste mit relevanten Zeitbereichen. Wird nicht verändert. Siehe auch Klassenbeschreibung für
weitere Informationen.newDataCollector
- Objekt, das benachrichtigt wird, wenn neue Daten vorliegen.
FailureException
- Falls es bei der Kommunikation mit der Konfiguration zu einem Fehler kommt.Method Detail |
---|
public OnlineDataReceiver createReceiver(Qualifier qualifier) throws FailureException
qualifier
- Datenidentifikation.
FailureException
- Falls es bei der Kommunikation mit der Konfiguration zu einem Fehler kommt.protected ClientDavInterface getDav()
ClientDavInterface#disconnect(boolean, java.lang.String)
)
werden!
protected java.util.List<Tuple<java.lang.Long,java.lang.Long>> getPeriods()
public ReceiveOptions getReceiveOptions()
public boolean dataAvailable()
true
falls noch Daten für einen Empfänger vorliegen.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |