Klasse, die beim Empfang von Datensätzen zur Entkopplung von Datenverteiler-Applikationsfunktionen und
Verarbeitungsfunktionen eingesetzt werden kann. Empfangene Datensätze werden in eine Queue eingetragen und asynchron
von einem eigenen Thread an die eigentlichen Empfänger weitergeleitet.
Wenn zum Beispiel statt
ClientReceiverInterface receiver= new ....;
connection.subscribeReceiver(receiver, ... );
der folgende Code bei der Anmeldung auf bestimmte Daten benutzt wird:
ClientReceiverInterface receiver= new ....;
ClientReceiverInterface asyncReceiver= new AsyncReceiver(receiver);
connection.subscribeReceiver(asyncReceiver, ... );
dann wird jeder empfangene Datensatz im Hintergrund verarbeitet.
Es ist zu beachten, dass die Klasse ein
einzigen Thread verwendet, der asynchron zu den anderen Aktivitäten der Applikation und insbesondere asynchron zum
update-Thread der Datenverteiler-Applikationsfunktionen arbeitet. Die in einer Queue zwischengespeicherten Datensätze
werden sequentiell an die update-Methode des eigentlichen Empfängers weiterleitet.