private static class AbstractSenderReceiverCommunication.DrainSubscription extends java.lang.Object implements ClientReceiverInterface, NonQueueingReceiver
Klasse, die mehrere Empfängsobjekte an einer Senke kapselt
Modifier and Type | Field and Description |
---|---|
private ClientDavInterface |
_connection |
private DataDescription |
_dataDescription |
private SystemObject |
_receiverObject |
private java.util.List<ClientReceiverInterface> |
_receivers |
Modifier | Constructor and Description |
---|---|
private |
DrainSubscription(ClientDavInterface connection,
SystemObject receiverObject,
DataDescription dataDescription) |
Modifier and Type | Method and Description |
---|---|
void |
subscribeReceiver(ClientReceiverInterface receiver) |
void |
unsubscribeReceiver(ClientReceiverInterface receiver) |
void |
update(ResultData[] results)
Aktualisierungsmethode, die nach Empfang eines angemeldeten Datensatzes von den Datenverteiler-Applikationsfunktionen aufgerufen wird.
|
private final java.util.List<ClientReceiverInterface> _receivers
private final ClientDavInterface _connection
private final SystemObject _receiverObject
private final DataDescription _dataDescription
private DrainSubscription(ClientDavInterface connection, SystemObject receiverObject, DataDescription dataDescription)
public void unsubscribeReceiver(ClientReceiverInterface receiver)
public void subscribeReceiver(ClientReceiverInterface receiver)
public void update(ResultData[] results)
ClientReceiverInterface
Aktualisierungsmethode, die nach Empfang eines angemeldeten Datensatzes von den Datenverteiler-Applikationsfunktionen aufgerufen wird. Diese Methode muss von der Applikation zur Verarbeitung der empfangenen Datensätze implementiert werden.
update
in interface ClientReceiverInterface
results
- Feld mit den empfangenen Ergebnisdatensätzen.