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.IOException
de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
public 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.IOException
de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
public 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?