de.bsvrz.dav.daf.main.impl.config.request.telegramManager
Class ConfigurationRequestReadData.AsynchronousAnswerReceiver

java.lang.Object
  extended by de.bsvrz.dav.daf.main.impl.config.request.telegramManager.ConfigurationRequestReadData.AsynchronousAnswerReceiver
All Implemented Interfaces:
AbstractSenderReceiverCommunication.DataListener, Runnable
Enclosing class:
ConfigurationRequestReadData

private final class ConfigurationRequestReadData.AsynchronousAnswerReceiver
extends Object
implements AbstractSenderReceiverCommunication.DataListener, Runnable


Field Summary
private  UnboundedQueue<Data> _unboundedQueue
           
 
Constructor Summary
private ConfigurationRequestReadData.AsynchronousAnswerReceiver()
           
 
Method Summary
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, 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()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_unboundedQueue

private final UnboundedQueue<Data> _unboundedQueue
Constructor Detail

ConfigurationRequestReadData.AsynchronousAnswerReceiver

private ConfigurationRequestReadData.AsynchronousAnswerReceiver()
Method Detail

messageReceived

public boolean messageReceived(Data data)
Description copied from interface: 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.

Specified by:
messageReceived in interface AbstractSenderReceiverCommunication.DataListener
Parameters:
data - Telegramm, das empfangen wurde
Returns:
true = Das Telegramm soll normal weiterverarbeitet werden; false = Das Telegramm wurde aus dem Strom der Telegramm entfernt und soll nicht weiter beachtet werden

close

public void close()
Description copied from interface: AbstractSenderReceiverCommunication.DataListener
Diese Methode wird aufgerufen, wenn die Kommunikation abgebrochen werden soll. Alle Sende/Empfangsanmeldungen, Threads, usw. sind zu beenden.

Specified by:
close in interface AbstractSenderReceiverCommunication.DataListener

actualizeMutableSet

private void actualizeMutableSet(Data data)
Aktualisiert die entsprechende dynamische Menge.

Parameters:
data - Das übermittelte Data von der Konfiguration.

actualizeMutableCollection

private void actualizeMutableCollection(Data data)
Aktualisiert die Elemente einer dynamischen Menge oder eines dynamischen Typs.

Parameters:
data - Das übermittelte Data von der Konfiguration.

actualizeConfigurationCommunicationState

private void actualizeConfigurationCommunicationState(Data data)
Aktualisiert den Kommunikationszustand für fremdverwaltete dynamische Mengen und Objekte.

Parameters:
data - Das übermittelte Data von der Konfiguration.

actualizeObject

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.

Parameters:
data - Aktuelle Daten für ein Objekt

getMessageDeserializer

private Deserializer getMessageDeserializer(Data reply,
                                            String expectedMessageType)
                                     throws RequestException
Throws:
RequestException

run

public void run()
Specified by:
run in interface Runnable