Package de.bsvrz.kex.kexdav.dataexchange
Class LowLevelDataPipe
- java.lang.Object
-
- de.bsvrz.kex.kexdav.dataexchange.LowLevelDataPipe
-
- Direct Known Subclasses:
LowLevelDataPipeDrain,LowLevelDataPipeSource
public abstract class LowLevelDataPipe extends java.lang.ObjectEmpfä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.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.String_aspSourceprotected java.lang.String_aspTargetprotected java.lang.String_atgSourceprotected java.lang.String_atgTargetprotected boolean_hasReceiverprotected boolean_hasSenderprotected ManagerInterface_managerprotected ObjectManagerInterface_objectManagerInterfaceprotected KExDaVDataPlugin_pluginprotected DataTransferPolicy_policyprotected de.bsvrz.dav.daf.main.ReceiveOptions_receiveOptionsprotected KExDaVReceiver_receiverprotected de.bsvrz.dav.daf.main.ReceiverRole_receiverRoleprotected KExDaVSender_senderprotected de.bsvrz.dav.daf.main.SenderRole_senderRoleprotected short_simulationVariantSourceprotected short_simulationVariantTargetprotected KExDaVObject_sourceprotected boolean_stopOnNextDataprotected KExDaVObject_target
-
Constructor Summary
Constructors Modifier Constructor Description protectedLowLevelDataPipe(ManagerInterface manager, java.lang.String aspTarget, ObjectManagerInterface objectManagerInterface, java.lang.String atgSource, KExDaVObject target, short simulationVariantTarget, java.lang.String atgTarget, short simulationVariantSource, java.lang.String aspSource, KExDaVDataPlugin plugin, de.bsvrz.dav.daf.main.ReceiverRole receiverRole, de.bsvrz.dav.daf.main.SenderRole senderRole, de.bsvrz.dav.daf.main.ReceiveOptions receiveOptions, KExDaVObject source)
-
Method Summary
Modifier and Type Method Description static LowLevelDataPipecreateLowLevelDataPipe(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 Datenverbindungsklassebooleanequals(java.lang.Object o)inthashCode()voidsetPolicy(DataTransferPolicy policy)Setzt das Austauschverfahren (sinnvollerweise zu setzen, bevor der Datenaustausch gestartet wird)abstract voidstart()Startet den DatentransfervoidstartOneTime()Führt nur einen Datenaustausch durchvoidstop()Stoppt den Datentransferjava.lang.StringtoString()protected abstract voidupdateSendControl(byte state)
-
-
-
Field Detail
-
_source
protected final KExDaVObject _source
-
_target
protected final KExDaVObject _target
-
_atgSource
protected final java.lang.String _atgSource
-
_atgTarget
protected final java.lang.String _atgTarget
-
_aspSource
protected final java.lang.String _aspSource
-
_aspTarget
protected final java.lang.String _aspTarget
-
_simulationVariantSource
protected final short _simulationVariantSource
-
_simulationVariantTarget
protected final short _simulationVariantTarget
-
_receiveOptions
protected final de.bsvrz.dav.daf.main.ReceiveOptions _receiveOptions
-
_plugin
protected final KExDaVDataPlugin _plugin
-
_receiverRole
protected final de.bsvrz.dav.daf.main.ReceiverRole _receiverRole
-
_senderRole
protected final de.bsvrz.dav.daf.main.SenderRole _senderRole
-
_objectManagerInterface
protected final ObjectManagerInterface _objectManagerInterface
-
_manager
protected final ManagerInterface _manager
-
_receiver
protected final KExDaVReceiver _receiver
-
_sender
protected final KExDaVSender _sender
-
_policy
protected DataTransferPolicy _policy
-
_hasSender
protected volatile boolean _hasSender
-
_hasReceiver
protected volatile boolean _hasReceiver
-
_stopOnNextData
protected volatile boolean _stopOnNextData
-
-
Constructor Detail
-
LowLevelDataPipe
protected LowLevelDataPipe(ManagerInterface manager, java.lang.String aspTarget, ObjectManagerInterface objectManagerInterface, java.lang.String atgSource, KExDaVObject target, short simulationVariantTarget, java.lang.String atgTarget, short simulationVariantSource, java.lang.String aspSource, KExDaVDataPlugin plugin, de.bsvrz.dav.daf.main.ReceiverRole receiverRole, de.bsvrz.dav.daf.main.SenderRole senderRole, de.bsvrz.dav.daf.main.ReceiveOptions receiveOptions, KExDaVObject source)
-
-
Method Detail
-
createLowLevelDataPipe
public static LowLevelDataPipe createLowLevelDataPipe(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- Returns:
- Datenverbindungsklasse
-
setPolicy
public void setPolicy(DataTransferPolicy policy)
Setzt das Austauschverfahren (sinnvollerweise zu setzen, bevor der Datenaustausch gestartet wird)- Parameters:
policy- Austauschverfahren
-
start
public abstract void start()
Startet den Datentransfer
-
stop
public void stop()
Stoppt den Datentransfer
-
startOneTime
public void startOneTime()
Führt nur einen Datenaustausch durch
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equalsin classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
updateSendControl
protected abstract void updateSendControl(byte state)
-
-