public class ProtocolRequestReceiver extends java.lang.Object implements ClientReceiverInterface
DataManager oder
TaskManager weiterleitet.| Modifier and Type | Field and Description |
|---|---|
private DataManager |
_dataManager |
private ClientDavInterface |
_dav |
private static Debug |
_debug
Debug Ausgaben
|
private ResultData |
_firstData
Erster Datensatz, der nach Anmeldung als Senke eingeht.
|
private DataModel |
_model |
private SystemObject |
_object |
private java.lang.Object |
_subscription
Synchronisationsobjekt.
|
private TaskManager |
_taskManager |
| Constructor and Description |
|---|
ProtocolRequestReceiver(ClientDavInterface dav,
DataManager dataManager,
TaskManager taskManager,
SystemObject object) |
| Modifier and Type | Method and Description |
|---|---|
void |
unsubscribe()
Meldet den Empfang von Protokoll-bezogenen Anfragen ab.
|
private void |
update(ResultData result) |
void |
update(ResultData[] results)
Aktualisierungsmethode, die nach Empfang eines angemeldeten Datensatzes von den Datenverteiler-Applikationsfunktionen aufgerufen wird.
|
private void |
waitForOk()
Wartet bis der Datenverteiler die Senken-Anmeldung bestätigt.
|
private DataManager _dataManager
private TaskManager _taskManager
private ClientDavInterface _dav
private DataModel _model
private SystemObject _object
private java.lang.Object _subscription
private ResultData _firstData
private static final Debug _debug
public ProtocolRequestReceiver(ClientDavInterface dav, DataManager dataManager, TaskManager taskManager, SystemObject object) throws ConfigurationException, FailureException
dav - Verbindung zum Datenverteiler.dataManager - Data-Manager.taskManager - Task-Manager.object - Objekt auf das sich der Receiver anmeldet.FailureException - Fehler beim Anmelden als Empfänger.ConfigurationException - Fehler bei der Kommunikation mit der Konfiguration.private void waitForOk()
throws FailureException
FailureException - Senke-Anmeldung ist fehlgeschlagenpublic void update(ResultData[] results)
de.bsvrz.dav.daf.main.ClientReceiverInterfaceupdate in interface ClientReceiverInterfaceresults - Feld mit den empfangenen Ergebnisdatensätzen.ClientReceiverInterface.update(ResultData[])private void update(ResultData result)
result - Auftragsparameter .Data von results darf nicht null sein!public void unsubscribe()