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.Object
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.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.String
_aspSource
protected java.lang.String
_aspTarget
protected java.lang.String
_atgSource
protected java.lang.String
_atgTarget
protected boolean
_hasReceiver
protected boolean
_hasSender
protected ManagerInterface
_manager
protected ObjectManagerInterface
_objectManagerInterface
protected KExDaVDataPlugin
_plugin
protected DataTransferPolicy
_policy
protected de.bsvrz.dav.daf.main.ReceiveOptions
_receiveOptions
protected KExDaVReceiver
_receiver
protected de.bsvrz.dav.daf.main.ReceiverRole
_receiverRole
protected KExDaVSender
_sender
protected de.bsvrz.dav.daf.main.SenderRole
_senderRole
protected short
_simulationVariantSource
protected short
_simulationVariantTarget
protected KExDaVObject
_source
protected boolean
_stopOnNextData
protected KExDaVObject
_target
-
Constructor Summary
Constructors Modifier Constructor Description 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 Summary
Modifier and Type Method Description 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 Datenverbindungsklasseboolean
equals(java.lang.Object o)
int
hashCode()
void
setPolicy(DataTransferPolicy policy)
Setzt das Austauschverfahren (sinnvollerweise zu setzen, bevor der Datenaustausch gestartet wird)abstract void
start()
Startet den Datentransfervoid
startOneTime()
Führt nur einen Datenaustausch durchvoid
stop()
Stoppt den Datentransferjava.lang.String
toString()
protected abstract void
updateSendControl(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:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
updateSendControl
protected abstract void updateSendControl(byte state)
-
-