public class AsyncReceiver extends java.lang.Object implements ClientReceiverInterface
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.
| Constructor and Description |
|---|
AsyncReceiver(ClientReceiverInterface syncReceiver)
Erzeugt ein neues Empfängerobjekt mit asynchroner Weiterleitung empfangener Daten an das übergebene Empfängerobjekt.
|
| Modifier and Type | Method and Description |
|---|---|
void |
update(ResultData[] results)
Aktualisierungsmethode, die nach Empfang eines angemeldeten Datensatzes von den Datenverteiler-Applikationsfunktionen aufgerufen wird.
|
public AsyncReceiver(ClientReceiverInterface syncReceiver)
Erzeugt ein neues Empfängerobjekt mit asynchroner Weiterleitung empfangener Daten an das übergebene Empfängerobjekt.
syncReceiver - Empfängerobjekt, an das empfangene Daten asynchron zur Verarbeitung weitergeleitet werden sollen.public void update(ResultData[] results)
Aktualisierungsmethode, die nach Empfang eines angemeldeten Datensatzes von den Datenverteiler-Applikationsfunktionen aufgerufen wird.
Empfangene Datensätze werden in eine Queue eingetragen und asynchron an das eigentliche Empfängerobjekt zur Verarbeitung weitergeleitet.
update in interface ClientReceiverInterfaceresults - Feld mit den empfangenen Ergebnisdatensätzen.