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.DataListener
Diese 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.DataListener
data
- Telegramm, das empfangen wurdepublic void close()
AbstractSenderReceiverCommunication.DataListener
Diese Methode wird aufgerufen, wenn die Kommunikation abgebrochen werden soll. Alle Sende/Empfangsanmeldungen, Threads, usw. sind zu beenden.
close
in interface AbstractSenderReceiverCommunication.DataListener
private 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
RequestException
public void run()
run
in interface java.lang.Runnable