public class DavTransactionManager extends Object
| Constructor and Description |
|---|
DavTransactionManager(ClientDavConnection connection,
TelegramManagerTransactionInterface telegramManager)
Erstellt einen neuen DavTransactionManager
|
| Modifier and Type | Method and Description |
|---|---|
void |
handleIncomingDrainData(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
|
List<ApplicationDataTelegram> |
handleTelegrams(List<ApplicationDataTelegram> telegrams,
boolean isSource)
Wird vom Subscriptionsmanager aufgerufen, wenn ein Telegram im Zentraldatenverteiler verarbeitet wird.
|
void |
notifyUnsubscribe(BaseSubscriptionInfo baseSubscriptionInfo,
boolean isSender)
Wird vom Subscriptionsmanager aufgerufen, um zu signalisieren, dass eine Datenanmeldung ungültig geworden ist.
|
public DavTransactionManager(ClientDavConnection connection, TelegramManagerTransactionInterface telegramManager)
connection - Verbindung zum DatenverteilertelegramManager - SubscriptionsManagerpublic List<ApplicationDataTelegram> handleTelegrams(List<ApplicationDataTelegram> telegrams, boolean isSource)
telegrams - Liste mit zusammengehörigen Telegrammen, die einen Datensatz darstellenisSource - Kommt der Datensatz von der lokalen Quelle? (Sonst lokale Senke)public void handleIncomingDrainData(ResultData result, de.bsvrz.dav.dav.main.DavTransactionManager.Subscription transactionSubscription)
result - ResultData aus dem inneren DatensatztransactionSubscription - Anmeldung der Transaktionssenkepublic void handleSubscribeTransactionSource(byte[] bytes)
throws IOException,
OneSubscriptionPerSendData
bytes - Serialisierte Info über DatenanmeldungIOExceptionOneSubscriptionPerSendDatapublic void handleSubscribeTransactionSource(de.bsvrz.dav.dav.main.DavTransactionManager.ClientSubscriptionInformation subscriptions)
throws OneSubscriptionPerSendData
subscriptions - AnmeldeinformationOneSubscriptionPerSendData - Fehler bei der Anmeldung (Z.B. es ist schon eine Senke vorhanden)public void handleSubscribeTransactionDrain(byte[] bytes)
throws IOException,
OneSubscriptionPerSendData
bytes - Serialisierte Info über DatenanmeldungIOExceptionOneSubscriptionPerSendDatapublic void handleSubscribeTransactionDrain(de.bsvrz.dav.dav.main.DavTransactionManager.ClientSubscriptionInformation subscriptions)
throws OneSubscriptionPerSendData
subscriptions - AnmeldeinformationOneSubscriptionPerSendData - Fehler bei der Anmeldung (Z.B. es ist schon eine Senke vorhanden)public void notifyUnsubscribe(BaseSubscriptionInfo baseSubscriptionInfo, boolean isSender)
baseSubscriptionInfo - Datenanmelde-InformationisSender - handelt es sich um eine sendende Anmeldung?