Package de.bsvrz.kex.kexdav.dataexchange
Class LowLevelDataPipeSource
- java.lang.Object
-
- de.bsvrz.kex.kexdav.dataexchange.LowLevelDataPipe
-
- de.bsvrz.kex.kexdav.dataexchange.LowLevelDataPipeSource
-
public class LowLevelDataPipeSource extends LowLevelDataPipe
Implementierung derLowLevelDataPipe
, bei der zuerst ein Empfänger angemeldet wird und wo dann je nach empfangenen Datensätzen (Keine Quelle oder nicht) die Quelle an- oder abgemeldet wird.
-
-
Field Summary
-
Fields inherited from class de.bsvrz.kex.kexdav.dataexchange.LowLevelDataPipe
_aspSource, _aspTarget, _atgSource, _atgTarget, _hasReceiver, _hasSender, _manager, _objectManagerInterface, _plugin, _policy, _receiveOptions, _receiver, _receiverRole, _sender, _senderRole, _simulationVariantSource, _simulationVariantTarget, _source, _stopOnNextData, _target
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
LowLevelDataPipeSource(KExDaVObject source, KExDaVObject target, java.lang.String atgSource, java.lang.String atgTarget, java.lang.String aspSource, java.lang.String aspTarget, short simulationVariantSource, short simulationVariantTarget, de.bsvrz.dav.daf.main.ReceiveOptions receiveOptions, de.bsvrz.dav.daf.main.ReceiverRole receiverRole, de.bsvrz.dav.daf.main.SenderRole senderRole, KExDaVDataPlugin plugin, ObjectManagerInterface objectManagerInterface, ManagerInterface manager)
Erstellt eine Datenverbindungsklasse
-
Method Summary
Modifier and Type Method Description protected void
sendDataToReceiver(KExDaVAttributeGroupData sourceData, de.bsvrz.dav.daf.main.DataState dataState, long dataTime, boolean delayed)
void
start()
Startet den Datentransferprotected void
updateSendControl(byte state)
-
Methods inherited from class de.bsvrz.kex.kexdav.dataexchange.LowLevelDataPipe
createLowLevelDataPipe, equals, hashCode, setPolicy, startOneTime, stop, toString
-
-
-
-
Constructor Detail
-
LowLevelDataPipeSource
protected LowLevelDataPipeSource(KExDaVObject source, KExDaVObject target, java.lang.String atgSource, java.lang.String atgTarget, java.lang.String aspSource, java.lang.String aspTarget, short simulationVariantSource, short simulationVariantTarget, de.bsvrz.dav.daf.main.ReceiveOptions receiveOptions, de.bsvrz.dav.daf.main.ReceiverRole receiverRole, de.bsvrz.dav.daf.main.SenderRole senderRole, KExDaVDataPlugin plugin, ObjectManagerInterface objectManagerInterface, ManagerInterface manager)
Erstellt eine Datenverbindungsklasse- Parameters:
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 desBasicKExDaVDataPlugin
.objectManagerInterface
- Verwaltung korrespondierender Objekte (optional)manager
- Callback für Ereignisse und Warnungen
-
-
Method Detail
-
start
public void start()
Description copied from class:LowLevelDataPipe
Startet den Datentransfer- Specified by:
start
in classLowLevelDataPipe
-
sendDataToReceiver
protected void sendDataToReceiver(KExDaVAttributeGroupData sourceData, de.bsvrz.dav.daf.main.DataState dataState, long dataTime, boolean delayed)
-
updateSendControl
protected void updateSendControl(byte state)
- Specified by:
updateSendControl
in classLowLevelDataPipe
-
-