public class DavTransactionManager
extends java.lang.Object
| Constructor | Description |
|---|---|
DavTransactionManager(de.bsvrz.dav.daf.main.ClientDavConnection connection,
TelegramManagerTransactionInterface telegramManager) |
Erstellt einen neuen DavTransactionManager
|
| Modifier and Type | Method | Description |
|---|---|---|
void |
handleIncomingDrainData(de.bsvrz.dav.daf.main.ResultData result,
de.bsvrz.dav.dav.main.DavTransactionManager.Subscription transactionSubscription) |
Wird von der Senke aufgerufen, die sich im Datenverteiler auf die inneren Datensätze von einer Transaktions-Senken-Anmeldung angemeldet hat.
|
void |
handleSubscribeTransactionDrain(byte[] bytes) |
Wird vom DavRequester aufgerufen um eine Transaktionssenke anzumelden
|
void |
handleSubscribeTransactionDrain(de.bsvrz.dav.dav.main.DavTransactionManager.ClientSubscriptionInformation subscriptions) |
Wird vom DavRequester aufgerufen um eine Transaktionssenke anzumelden
|
void |
handleSubscribeTransactionSource(byte[] bytes) |
Wird vom DavRequester aufgerufen um eine Transaktionsquelle anzumelden
|
void |
handleSubscribeTransactionSource(de.bsvrz.dav.dav.main.DavTransactionManager.ClientSubscriptionInformation subscriptions) |
Wird vom DavRequester aufgerufen um eine Transaktionsquelle anzumelden
|
java.util.List<de.bsvrz.dav.daf.communication.lowLevel.telegrams.ApplicationDataTelegram> |
handleTelegrams(java.util.List<de.bsvrz.dav.daf.communication.lowLevel.telegrams.ApplicationDataTelegram> telegrams,
long applicationId,
boolean isSource) |
Wird vom Subscriptionsmanager aufgerufen, wenn ein Telegram im Zentraldatenverteiler verarbeitet wird.
|
void |
notifyUnsubscribe(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo,
boolean isSender) |
Wird vom Subscriptionsmanager aufgerufen, um zu signalisieren, dass eine Datenanmeldung ungültig geworden ist.
|
public DavTransactionManager(de.bsvrz.dav.daf.main.ClientDavConnection connection,
TelegramManagerTransactionInterface telegramManager)
connection - Verbindung zum DatenverteilertelegramManager - SubscriptionsManagerpublic java.util.List<de.bsvrz.dav.daf.communication.lowLevel.telegrams.ApplicationDataTelegram> handleTelegrams(java.util.List<de.bsvrz.dav.daf.communication.lowLevel.telegrams.ApplicationDataTelegram> telegrams,
long applicationId,
boolean isSource)
telegrams - Liste mit zusammengehörigen Telegrammen, die einen Datensatz darstellenapplicationId - ID der sendenden ApplikationisSource - Kommt der Datensatz von der lokalen Quelle? (Sonst lokale Senke)public void handleIncomingDrainData(de.bsvrz.dav.daf.main.ResultData result,
de.bsvrz.dav.dav.main.DavTransactionManager.Subscription transactionSubscription)
result - ResultData aus dem inneren DatensatztransactionSubscription - Anmeldung der Transaktionssenkepublic void handleSubscribeTransactionSource(byte[] bytes)
throws java.io.IOException,
de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
bytes - Serialisierte Info über Datenanmeldungjava.io.IOExceptionde.bsvrz.dav.daf.main.OneSubscriptionPerSendDatapublic void handleSubscribeTransactionSource(de.bsvrz.dav.dav.main.DavTransactionManager.ClientSubscriptionInformation subscriptions)
throws de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
subscriptions - Anmeldeinformationde.bsvrz.dav.daf.main.OneSubscriptionPerSendData - Fehler bei der Anmeldung (Z.B. es ist schon eine Senke vorhanden)public void handleSubscribeTransactionDrain(byte[] bytes)
throws java.io.IOException,
de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
bytes - Serialisierte Info über Datenanmeldungjava.io.IOExceptionde.bsvrz.dav.daf.main.OneSubscriptionPerSendDatapublic void handleSubscribeTransactionDrain(de.bsvrz.dav.dav.main.DavTransactionManager.ClientSubscriptionInformation subscriptions)
throws de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
subscriptions - Anmeldeinformationde.bsvrz.dav.daf.main.OneSubscriptionPerSendData - Fehler bei der Anmeldung (Z.B. es ist schon eine Senke vorhanden)public void notifyUnsubscribe(de.bsvrz.dav.daf.communication.lowLevel.telegrams.BaseSubscriptionInfo baseSubscriptionInfo,
boolean isSender)
baseSubscriptionInfo - Datenanmelde-InformationisSender - handelt es sich um eine sendende Anmeldung?