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 DatenanmeldungIOException
OneSubscriptionPerSendData
public 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 DatenanmeldungIOException
OneSubscriptionPerSendData
public 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?