private final class ConfigurationRequestReadData.AsynchronousAnswerReceiver extends java.lang.Object implements AbstractSenderReceiverCommunication.DataListener, java.lang.Runnable
| Modifier and Type | Field and Description |
|---|---|
private UnboundedQueue<Data> |
_unboundedQueue |
| Modifier | Constructor and Description |
|---|---|
private |
AsynchronousAnswerReceiver() |
| Modifier and Type | Method and Description |
|---|---|
private void |
actualizeConfigurationCommunicationState(Data data)
Aktualisiert den Kommunikationszustand für fremdverwaltete dynamische Mengen und Objekte.
|
private void |
actualizeMutableCollection(Data data)
Aktualisiert die Elemente einer dynamischen Menge oder eines dynamischen Typs.
|
private void |
actualizeMutableSet(Data data)
Aktualisiert die entsprechende dynamische Menge.
|
private void |
actualizeObject(Data data)
Ein Objekt wurde auf Seiten der Konfiguration verändert und die Konfiguration benachrichtigt alle Applikationen.
|
void |
close()
Diese Methode wird aufgerufen, wenn die Kommunikation abgebrochen werden soll.
|
private Deserializer |
getMessageDeserializer(Data reply,
java.lang.String expectedMessageType) |
boolean |
messageReceived(Data data)
Diese Methode wird aufgerufen, sobald eine Instanz von
AbstractSenderReceiverCommunication ein Telegramm in der update-Methode empfängt. |
void |
run() |
private final UnboundedQueue<Data> _unboundedQueue
public boolean messageReceived(Data data)
AbstractSenderReceiverCommunication.DataListenerDiese Methode wird aufgerufen, sobald eine Instanz von AbstractSenderReceiverCommunication ein Telegramm in der update-Methode empfängt. Das Telegramm kann normal weiter verarbeitet werden oder aber aus dem Strom der Telegramme entfernt werden.
messageReceived in interface AbstractSenderReceiverCommunication.DataListenerdata - Telegramm, das empfangen wurdepublic void close()
AbstractSenderReceiverCommunication.DataListenerDiese Methode wird aufgerufen, wenn die Kommunikation abgebrochen werden soll. Alle Sende/Empfangsanmeldungen, Threads, usw. sind zu beenden.
close in interface AbstractSenderReceiverCommunication.DataListenerprivate void actualizeMutableSet(Data data)
Aktualisiert die entsprechende dynamische Menge.
data - Das übermittelte Data von der Konfiguration.private void actualizeMutableCollection(Data data)
Aktualisiert die Elemente einer dynamischen Menge oder eines dynamischen Typs.
data - Das übermittelte Data von der Konfiguration.private void actualizeConfigurationCommunicationState(Data data)
Aktualisiert den Kommunikationszustand für fremdverwaltete dynamische Mengen und Objekte.
data - Das übermittelte Data von der Konfiguration.private void actualizeObject(Data data)
Ein Objekt wurde auf Seiten der Konfiguration verändert und die Konfiguration benachrichtigt alle Applikationen. Die Applikationen müssen nun ihre Daten auf den neusten Stand bringen.
data - Aktuelle Daten für ein Objektprivate Deserializer getMessageDeserializer(Data reply, java.lang.String expectedMessageType) throws RequestException
RequestExceptionpublic void run()
run in interface java.lang.Runnable