Package de.bsvrz.dav.daf.main
Class TransactionManager
java.lang.Object
de.bsvrz.dav.daf.main.TransactionManager
- All Implemented Interfaces:
Transactions
Klasse, die Transaktionen verwaltet.
-
Constructor Summary
ConstructorsConstructorDescriptionTransactionManager
(ClientDavConnection connection) Erstellt einen neuen TransaktionsManager zur Verwaltung von Transaktionen -
Method Summary
Modifier and TypeMethodDescriptionvoid
sendTransaction
(TransactionDataDescription dataDescription, Collection<ResultData> data) Sendet eine Transaktion mit dem Transaktiondatensatz-Zeitstempel der aktuellen Zeit.void
sendTransaction
(TransactionDataDescription dataDescription, Collection<ResultData> data, long dataTime) Sendet eine Transaktionvoid
Sendet eine Transaktionvoid
subscribeDrain
(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions) Meldet eine Transaktionssenke an.void
subscribeReceiver
(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription) Meldet einen Transaktionsempfänger an.void
subscribeSender
(TransactionSenderInterface sender, TransactionDataDescription dataDescription) Meldet einen Transaktionssender an.void
subscribeSource
(TransactionSenderInterface sender, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions) Meldet eine Transaktionsquelle an und sendet einen leeren Datensatz.void
subscribeSource
(TransactionSenderInterface sender, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions, Collection<ResultData> initialData, long time) Meldet eine Transaktionsquelle an und sendet einen Transaktionsdatensatz.toString()
void
unsubscribeReceiver
(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription) Meldet einen Transaktionempfänger oder eine Transaktionssenke ab.void
unsubscribeSender
(TransactionSenderInterface sender, TransactionDataDescription dataDescription) Meldet einen Transaktionsender oder eine Transaktionsquelle ab.
-
Constructor Details
-
TransactionManager
Erstellt einen neuen TransaktionsManager zur Verwaltung von Transaktionen- Parameters:
connection
- Verbindung zum Datenverteiler
-
-
Method Details
-
subscribeSource
public void subscribeSource(TransactionSenderInterface sender, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions, Collection<ResultData> initialData, long time) throws OneSubscriptionPerSendData Description copied from interface:Transactions
Meldet eine Transaktionsquelle an und sendet einen Transaktionsdatensatz.- Specified by:
subscribeSource
in interfaceTransactions
- Parameters:
sender
- Callback zur SendesteuerungdataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)subscriptions
- Datenidentifikationen innerhalb der TransaktioninitialData
- Initialer Datensatztime
- Datenzeit des Transaktionsdatensatzes- Throws:
OneSubscriptionPerSendData
- Falls es schon eine Quellen-Anmeldung zu dieser Transaktion oder einem enthaltenen Datensatz gibt.
-
sendTransaction
public void sendTransaction(TransactionDataDescription dataDescription, Collection<ResultData> data) throws SendSubscriptionNotConfirmed Description copied from interface:Transactions
Sendet eine Transaktion mit dem Transaktiondatensatz-Zeitstempel der aktuellen Zeit. Innere Daten können einen anderen Zeitstempel haben.- Specified by:
sendTransaction
in interfaceTransactions
- Parameters:
dataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)data
- Liste mit Daten- Throws:
SendSubscriptionNotConfirmed
- Bei fehlender Sender-Anmeldung
-
sendTransaction
public void sendTransaction(TransactionDataDescription dataDescription, Collection<ResultData> data, long dataTime) throws SendSubscriptionNotConfirmed Description copied from interface:Transactions
Sendet eine Transaktion- Specified by:
sendTransaction
in interfaceTransactions
- Parameters:
dataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)data
- Liste mit DatendataTime
- Datenzeit (des Transaktionsdatensatzes)- Throws:
SendSubscriptionNotConfirmed
- Bei fehlender Sender-Anmeldung
-
sendTransaction
Description copied from interface:Transactions
Sendet eine Transaktion- Specified by:
sendTransaction
in interfaceTransactions
- Parameters:
data
- Transaktion- Throws:
SendSubscriptionNotConfirmed
- Bei fehlender Sender-Anmeldung
-
unsubscribeReceiver
public void unsubscribeReceiver(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription) Description copied from interface:Transactions
Meldet einen Transaktionempfänger oder eine Transaktionssenke ab.- Specified by:
unsubscribeReceiver
in interfaceTransactions
- Parameters:
receiver
- Empfänger-KlassedataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)
-
unsubscribeSender
public void unsubscribeSender(TransactionSenderInterface sender, TransactionDataDescription dataDescription) Description copied from interface:Transactions
Meldet einen Transaktionsender oder eine Transaktionsquelle ab.- Specified by:
unsubscribeSender
in interfaceTransactions
- Parameters:
sender
- Sender-KlassedataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)
-
subscribeSource
public void subscribeSource(TransactionSenderInterface sender, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions) throws OneSubscriptionPerSendData Description copied from interface:Transactions
Meldet eine Transaktionsquelle an und sendet einen leeren Datensatz.- Specified by:
subscribeSource
in interfaceTransactions
- Parameters:
sender
- Callback zur SendesteuerungdataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)subscriptions
- Datenidentifikationen innerhalb der Transaktion- Throws:
OneSubscriptionPerSendData
- Falls es schon eine Quellen-Anmeldung zu dieser Transaktion oder einem enthaltenen Datensatz gibt.
-
subscribeSender
public void subscribeSender(TransactionSenderInterface sender, TransactionDataDescription dataDescription) throws OneSubscriptionPerSendData Description copied from interface:Transactions
Meldet einen Transaktionssender an.- Specified by:
subscribeSender
in interfaceTransactions
- Parameters:
sender
- Callback zur SendesteuerungdataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)- Throws:
OneSubscriptionPerSendData
- Falls es schon eine widersprüchliche Anmeldung zu dieser Transaktion oder einem enthaltenen Datensatz gibt.
-
subscribeReceiver
public void subscribeReceiver(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription) throws OneSubscriptionPerSendData Description copied from interface:Transactions
Meldet einen Transaktionsempfänger an.- Specified by:
subscribeReceiver
in interfaceTransactions
- Parameters:
receiver
- Callback zum Empfang von DatendataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)- Throws:
OneSubscriptionPerSendData
- Falls es schon eine widersprüchliche Anmeldung zu dieser Transaktion oder einem enthaltenen Datensatz gibt.
-
subscribeDrain
public void subscribeDrain(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions) throws OneSubscriptionPerSendData Description copied from interface:Transactions
Meldet eine Transaktionssenke an.- Specified by:
subscribeDrain
in interfaceTransactions
- Parameters:
receiver
- Callback zum Empfang von DatendataDescription
- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)subscriptions
- Datenidentifikationen innerhalb der Transaktion- Throws:
OneSubscriptionPerSendData
- Falls es schon eine widersprüchliche Anmeldung zu dieser Transaktion oder einem enthaltenen Datensatz gibt.
-
toString
-