public class Sender
extends java.lang.Object
implements de.bsvrz.dav.daf.main.ClientSenderInterface
SimpleSender
ist diese Klasse zum
Versand von Massendaten gedacht.SubscriptionManager
Modifier | Constructor and Description |
---|---|
protected |
Sender(de.bsvrz.dav.daf.main.ClientDavInterface dav,
de.bsvrz.dav.daf.main.config.SystemObject receiver,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
Modifier and Type | Method and Description |
---|---|
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription,
byte state) |
de.bsvrz.dav.daf.main.DataDescription |
getDataDescription() |
de.bsvrz.dav.daf.main.ClientDavInterface |
getDav() |
byte |
getLastState() |
de.bsvrz.dav.daf.main.config.SystemObject |
getReceiver() |
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object,
de.bsvrz.dav.daf.main.DataDescription dataDescription) |
boolean |
send(de.bsvrz.dav.daf.main.Data data)
Sendet die spezifizierten Daten als "online aktuell" mit der aktuellen Systemzeit.
|
boolean |
send(de.bsvrz.dav.daf.main.Data data,
boolean delayed)
Sendet die spezifizierten Daten mit der aktuellen Systemzeit.
|
boolean |
send(de.bsvrz.dav.daf.main.Data data,
long dataTime,
boolean delayed)
Sendet die spezifizierten Daten.
|
boolean |
sendIfPosSendCtrl(de.bsvrz.dav.daf.main.Data data)
Sendet die spezifizierten Daten als "online aktuell" mit der aktuellen Systemzeit.
|
void |
sendIfPosSendCtrl(de.bsvrz.dav.daf.main.Data data,
boolean delayed)
Sendet die spezifizierten Daten mit der aktuellen Systemzeit.
|
void |
sendIfPosSendCtrl(de.bsvrz.dav.daf.main.Data data,
long dataTime,
boolean delayed)
Sendet die spezifizierten Daten mit der aktuellen Systemzeit.
|
void |
sendIgnoreSendControl(de.bsvrz.dav.daf.main.Data data,
long dataTime,
boolean delayed)
Sendet Daten ohne auf die Sendesteuerung zu achten.
|
static Sender |
subscribe(de.bsvrz.dav.daf.main.ClientDavInterface dav,
de.bsvrz.dav.daf.main.config.SystemObject receiver,
java.lang.String attributeGroup,
java.lang.String aspect,
de.bsvrz.dav.daf.main.SenderRole srole)
Erzeugt einen Sender.
|
static Sender |
subscribeSender(de.bsvrz.dav.daf.main.ClientDavInterface dav,
java.lang.String sysObj,
java.lang.String attributeGroup,
java.lang.String aspect)
Erzeugt einen einfachen Sender.
|
static Sender |
subscribeSender(de.bsvrz.dav.daf.main.ClientDavInterface dav,
de.bsvrz.dav.daf.main.config.SystemObject sysObj,
java.lang.String attributeGroup,
java.lang.String aspect)
Erzeugt einen einfachen Sender.
|
static Sender |
subscribeSource(de.bsvrz.dav.daf.main.ClientDavInterface dav,
java.lang.String sysObj,
java.lang.String attributeGroup,
java.lang.String aspect)
Erzeugt eine Quelle.
|
boolean |
unsubscribe()
Meldet den Versand von Daten ab.
|
protected Sender(de.bsvrz.dav.daf.main.ClientDavInterface dav, de.bsvrz.dav.daf.main.config.SystemObject receiver, de.bsvrz.dav.daf.main.DataDescription dataDescription)
public static Sender subscribe(de.bsvrz.dav.daf.main.ClientDavInterface dav, de.bsvrz.dav.daf.main.config.SystemObject receiver, java.lang.String attributeGroup, java.lang.String aspect, de.bsvrz.dav.daf.main.SenderRole srole) throws FailureException
dav
- Verbindung zum Datenverteiler.receiver
- Empfänger.attributeGroup
- Attributgruppe.aspect
- Aspekt.srole
- Quelle oder 'einfahcer' Sender.FailureException
- Fehler bei der Kommunikation mit der Konfiguration. Oder: Es existiert bereits eine Sendeanmeldung.public static Sender subscribeSender(de.bsvrz.dav.daf.main.ClientDavInterface dav, de.bsvrz.dav.daf.main.config.SystemObject sysObj, java.lang.String attributeGroup, java.lang.String aspect) throws FailureException
dav
- Verbindung zum Datenverteiler.sysObj
- Empfänger.attributeGroup
- Attributgruppe-PIDaspect
- Aspekt-PIDFailureException
- Fehler bei der Kommunikation mit der Konfiguration. Oder: Es existiert bereits eine Sendeanmeldung.public static Sender subscribeSender(de.bsvrz.dav.daf.main.ClientDavInterface dav, java.lang.String sysObj, java.lang.String attributeGroup, java.lang.String aspect) throws FailureException
dav
- Verbindung zum Datenverteiler.sysObj
- Pid des Objekts, für das die Anmeldung giltattributeGroup
- Attributgruppe-PIDaspect
- Aspekt-PIDFailureException
- Fehler bei der Kommunikation mit der Konfiguration. Oder: Es existiert bereits eine Sendeanmeldung.public static Sender subscribeSource(de.bsvrz.dav.daf.main.ClientDavInterface dav, java.lang.String sysObj, java.lang.String attributeGroup, java.lang.String aspect) throws FailureException
dav
- Verbindung zum Datenverteiler.sysObj
- Objekt für das die Anmeldung gilt.attributeGroup
- Attributgruppe-PIDaspect
- Aspekt-PIDFailureException
- Fehler bei der Kommunikation mit der Konfiguration. Oder: Es existiert bereits eine Sendeanmeldung.public boolean unsubscribe()
false
falls die Abmeldung nicht durchgeführt werden konnte.public boolean send(de.bsvrz.dav.daf.main.Data data) throws FailureException
data
- Zu sendende Daten.true
falls die Daten gesendet wurden, false
falls der Versand von der Sendesteuerung gestoppt wurde.FailureException
public boolean send(de.bsvrz.dav.daf.main.Data data, boolean delayed) throws FailureException
data
- Zu sendende Daten.delayed
- falls wahr, werden Daten als nachgeliefert gekennzeichnettrue
falls die Daten gesendet wurden, false
falls der Versand von der Sendesteuerung gestoppt wurde.FailureException
public boolean send(de.bsvrz.dav.daf.main.Data data, long dataTime, boolean delayed) throws FailureException
data
- Zu sendende Daten.dataTime
- Datenzeitstempel des zu sendenden Datensatzesdelayed
- falls wahr, werden Daten als nachgeliefert gekennzeichnettrue
falls die Daten gesendet wurden, false
falls der Versand von der Sendesteuerung gestoppt wurde.FailureException
public boolean sendIfPosSendCtrl(de.bsvrz.dav.daf.main.Data data) throws FailureException
data
- Zu sendende Daten.FailureException
public void sendIfPosSendCtrl(de.bsvrz.dav.daf.main.Data data, boolean delayed) throws FailureException
data
- Zu sendende Daten.delayed
- falls wahr, werden Daten als nachgeliefert gekennzeichnetFailureException
public void sendIfPosSendCtrl(de.bsvrz.dav.daf.main.Data data, long dataTime, boolean delayed) throws FailureException
data
- Zu sendende Daten.dataTime
- Datenzeitstempel des zu sendenden Datensatzesdelayed
- falls wahr, werden Daten als nachgeliefert gekennzeichnetFailureException
public void sendIgnoreSendControl(de.bsvrz.dav.daf.main.Data data, long dataTime, boolean delayed) throws FailureException
data
- Zu sendende Daten.dataTime
- Datenzeitstempel des zu sendenden Datensatzesdelayed
- wahr, falls Daten als nachgeliefert gekennzeichnet werden sollenFailureException
public void dataRequest(de.bsvrz.dav.daf.main.config.SystemObject object, de.bsvrz.dav.daf.main.DataDescription dataDescription, byte state)
dataRequest
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
ClientSenderInterface.dataRequest(SystemObject,DataDescription,byte)
public byte getLastState()
public boolean isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject object, de.bsvrz.dav.daf.main.DataDescription dataDescription)
isRequestSupported
in interface de.bsvrz.dav.daf.main.ClientSenderInterface
ClientSenderInterface.isRequestSupported(SystemObject,DataDescription)
public de.bsvrz.dav.daf.main.ClientDavInterface getDav()
public de.bsvrz.dav.daf.main.config.SystemObject getReceiver()
public de.bsvrz.dav.daf.main.DataDescription getDataDescription()