Package de.bsvrz.dav.daf.main
Class TransactionManager
- java.lang.Object
-
- de.bsvrz.dav.daf.main.TransactionManager
-
- All Implemented Interfaces:
Transactions
public class TransactionManager extends java.lang.Object implements Transactions
Klasse, die Transaktionen verwaltet.
-
-
Constructor Summary
Constructors Constructor Description TransactionManager(ClientDavConnection connection)Erstellt einen neuen TransaktionsManager zur Verwaltung von Transaktionen
-
Method Summary
Modifier and Type Method Description voidsendTransaction(TransactionDataDescription dataDescription, java.util.Collection<ResultData> data)Sendet eine Transaktion mit dem Transaktiondatensatz-Zeitstempel der aktuellen Zeit.voidsendTransaction(TransactionDataDescription dataDescription, java.util.Collection<ResultData> data, long dataTime)Sendet eine TransaktionvoidsendTransaction(TransactionResultData data)Sendet eine TransaktionvoidsubscribeDrain(TransactionReceiverInterface receiver, TransactionDataDescription dataDescription, java.util.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, java.util.Collection<InnerDataSubscription> subscriptions)Meldet eine Transaktionsquelle an und sendet einen leeren Datensatz.voidsubscribeSource(TransactionSenderInterface sender, TransactionDataDescription dataDescription, java.util.Collection<InnerDataSubscription> subscriptions, java.util.Collection<ResultData> initialData, long time)Meldet eine Transaktionsquelle an und sendet einen Transaktionsdatensatz.java.lang.StringtoString()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 Detail
-
TransactionManager
public TransactionManager(ClientDavConnection connection)
Erstellt einen neuen TransaktionsManager zur Verwaltung von Transaktionen- Parameters:
connection- Verbindung zum Datenverteiler
-
-
Method Detail
-
subscribeSource
public void subscribeSource(TransactionSenderInterface sender, TransactionDataDescription dataDescription, java.util.Collection<InnerDataSubscription> subscriptions, java.util.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, java.util.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, java.util.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
public void sendTransaction(TransactionResultData data) throws SendSubscriptionNotConfirmed
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, java.util.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, java.util.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
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-