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 TypeMethodDescriptionvoidsendTransaction(TransactionDataDescription dataDescription, Collection<ResultData> data) Sendet eine Transaktion mit dem Transaktiondatensatz-Zeitstempel der aktuellen Zeit.voidsendTransaction(TransactionDataDescription dataDescription, Collection<ResultData> data, long dataTime) Sendet eine TransaktionvoidSendet eine TransaktionvoidsubscribeDrain(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions) Meldet eine Transaktionssenke an.voidsubscribeReceiver(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription) Meldet einen Transaktionsempfänger an.voidsubscribeSender(TransactionSenderInterface sender, TransactionDataDescription dataDescription) Meldet einen Transaktionssender an.voidsubscribeSource(TransactionSenderInterface sender, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions) Meldet eine Transaktionsquelle an und sendet einen leeren Datensatz.voidsubscribeSource(TransactionSenderInterface sender, TransactionDataDescription dataDescription, Collection<InnerDataSubscription> subscriptions, Collection<ResultData> initialData, long time) Meldet eine Transaktionsquelle an und sendet einen Transaktionsdatensatz.toString()voidunsubscribeReceiver(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription) Meldet einen Transaktionempfänger oder eine Transaktionssenke ab.voidunsubscribeSender(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:TransactionsMeldet eine Transaktionsquelle an und sendet einen Transaktionsdatensatz.- Specified by:
subscribeSourcein 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:TransactionsSendet eine Transaktion mit dem Transaktiondatensatz-Zeitstempel der aktuellen Zeit. Innere Daten können einen anderen Zeitstempel haben.- Specified by:
sendTransactionin 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:TransactionsSendet eine Transaktion- Specified by:
sendTransactionin 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:TransactionsSendet eine Transaktion- Specified by:
sendTransactionin interfaceTransactions- Parameters:
data- Transaktion- Throws:
SendSubscriptionNotConfirmed- Bei fehlender Sender-Anmeldung
-
unsubscribeReceiver
public void unsubscribeReceiver(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription) Description copied from interface:TransactionsMeldet einen Transaktionempfänger oder eine Transaktionssenke ab.- Specified by:
unsubscribeReceiverin interfaceTransactions- Parameters:
receiver- Empfänger-KlassedataDescription- Datenidentifikation der Transaktion (Transaktionsobjekt, -attributgruppe, -aspekt)
-
unsubscribeSender
public void unsubscribeSender(TransactionSenderInterface sender, TransactionDataDescription dataDescription) Description copied from interface:TransactionsMeldet einen Transaktionsender oder eine Transaktionsquelle ab.- Specified by:
unsubscribeSenderin 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:TransactionsMeldet eine Transaktionsquelle an und sendet einen leeren Datensatz.- Specified by:
subscribeSourcein 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:TransactionsMeldet einen Transaktionssender an.- Specified by:
subscribeSenderin 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:TransactionsMeldet einen Transaktionsempfänger an.- Specified by:
subscribeReceiverin 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:TransactionsMeldet eine Transaktionssenke an.- Specified by:
subscribeDrainin 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
-