|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.kex.kexdav.dataexchange.LowLevelDataPipe
public class LowLevelDataPipe
Empfängt Daten von einem Objekt in einem Datenverteiler und sendet diese an das gleiche oder ein anderes Objekt (vorzugsweise auf einem anderen Datenverteiler), evtl. unter Benutzung einer anderen Attributgruppe und eines anderen Aspekts sowie unter Zuhilfenahme eines Plugins, das die Daten gegebenenfalls anpasst, falls z.B. unterschiedliche Attributgruppen vorliegen.
Nested Class Summary | |
---|---|
private class |
LowLevelDataPipe.MyReceiver
|
Field Summary | |
---|---|
private String |
_aspSource
|
private String |
_aspTarget
|
private String |
_atgSource
|
private String |
_atgTarget
|
private boolean |
_hasReceiver
|
private boolean |
_hasSender
|
private ManagerInterface |
_manager
|
private ObjectManagerInterface |
_objectManagerInterface
|
private KExDaVDataPlugin |
_plugin
|
private DataTransferPolicy |
_policy
|
private ReceiveOptions |
_receiveOptions
|
private KExDaVReceiver |
_receiver
|
private ReceiverRole |
_receiverRole
|
private SenderRole |
_senderRole
|
private short |
_simulationVariantSource
|
private short |
_simulationVariantTarget
|
private KExDaVObject |
_source
|
private boolean |
_stopOnNextData
|
private KExDaVObject |
_target
|
Constructor Summary | |
---|---|
LowLevelDataPipe(KExDaVObject source,
KExDaVObject target,
String atgSource,
String atgTarget,
String aspSource,
String aspTarget,
short simulationVariantSource,
short simulationVariantTarget,
ReceiveOptions receiveOptions,
ReceiverRole receiverRole,
SenderRole senderRole,
KExDaVDataPlugin plugin,
ObjectManagerInterface objectManagerInterface,
ManagerInterface manager)
Erstellt eine Datenverbindungsklasse |
Method Summary | |
---|---|
boolean |
equals(Object o)
|
int |
hashCode()
|
(package private) void |
sendDataToReceiver(KExDaVAttributeGroupData sourceData,
DataState dataState,
long dataTime)
Sendet die Daten weiter an den Empfänger. |
void |
setPolicy(DataTransferPolicy policy)
Setzt das Austauschverfahren (sinnvollerweise zu setzen, bevor der Datenaustausch gestartet wird) |
void |
start()
Startet den Datentransfer |
void |
startOneTime()
Führt nur einen Datenaustausch durch |
void |
stop()
Stoppt den Datentransfer |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
private final KExDaVObject _source
private final KExDaVObject _target
private final String _atgSource
private final String _atgTarget
private final String _aspSource
private final String _aspTarget
private final short _simulationVariantSource
private final short _simulationVariantTarget
private final ReceiveOptions _receiveOptions
private final KExDaVDataPlugin _plugin
private volatile boolean _hasSender
private volatile boolean _hasReceiver
private final KExDaVReceiver _receiver
private final ReceiverRole _receiverRole
private final SenderRole _senderRole
private final ObjectManagerInterface _objectManagerInterface
private final ManagerInterface _manager
private volatile boolean _stopOnNextData
private DataTransferPolicy _policy
Constructor Detail |
---|
public LowLevelDataPipe(KExDaVObject source, KExDaVObject target, String atgSource, String atgTarget, String aspSource, String aspTarget, short simulationVariantSource, short simulationVariantTarget, ReceiveOptions receiveOptions, ReceiverRole receiverRole, SenderRole senderRole, KExDaVDataPlugin plugin, ObjectManagerInterface objectManagerInterface, ManagerInterface manager)
source
- Quell-Objekttarget
- Ziel-ObjektatgSource
- Quell-AtgatgTarget
- Ziel-AtgaspSource
- Quell-AspektaspTarget
- Ziel-AspektsimulationVariantSource
- Quell-SimulationsvariantesimulationVariantTarget
- Ziel-SimulationsvariantereceiveOptions
- Nur geänderte Daten übertragen?receiverRole
- Art der Anmeldung im QuellsystemsenderRole
- Art der Anmeldung im Zielsystemplugin
- Modul, das das Kopieren und gegebenenfalls anpassen der Daten übernimmt. Im einfachsten Fall eine Instanz des BasicKExDaVDataPlugin
.objectManagerInterface
- Verwaltung korrespondierender Objekte (optional)manager
- Callback für Ereignisse und WarnungenMethod Detail |
---|
public void setPolicy(DataTransferPolicy policy)
policy
- Austauschverfahrenpublic void start()
public void stop()
public void startOneTime()
void sendDataToReceiver(KExDaVAttributeGroupData sourceData, DataState dataState, long dataTime)
_policy
aufgerufen.
sourceData
- DatendataState
- DatenzustanddataTime
- Datenzeitpublic boolean equals(Object o)
equals
in class Object
public int hashCode()
hashCode
in class Object
public String toString()
toString
in class Object
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |