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.ClientReceiverInterface
update
in interface ClientReceiverInterface
results
- 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()