public class GlSpeicherClient extends Object implements GlSpeicherClientInterface, de.bsvrz.dav.daf.main.ClientReceiverInterface, de.bsvrz.dav.daf.main.ClientSenderInterface
| Modifier and Type | Field and Description |
|---|---|
private de.bsvrz.dav.daf.main.DataDescription |
anfrageDataDescription
Datenbeschreibung von Anfragen an den Ganglinien-Server.
|
private static long |
anfrageId
Anfrage-ID-Zaehler.
|
private de.bsvrz.dav.daf.main.config.SystemObject |
app
Applikations-ID.
|
private de.bsvrz.dav.daf.main.ClientDavInterface |
dav
Datenverteiler-Verbindung.
|
private static Map<de.bsvrz.sys.funclib.bitctrl.modell.ObjektFactory,GlSpeicherClient> |
davZuClientMap
Pro Objektfactory ein statischer GL-Client.
|
private boolean |
inWait
Indiziert, ob dieser Prozess gerade auf eine Antwort vom Server wartet.
|
private de.bsvrz.dav.daf.main.ResultData |
lastResult
Die letzte empfangene Antwort vom Server.
|
private de.bsvrz.sys.funclib.bitctrl.modell.ObjektFactory |
objektFactory
DAV-Objektfactory.
|
private static int |
REQ_DELETE
Kommando zum Loaeschen aller Ganglinien an einem MQ.
|
private static int |
REQ_GETSET
Kommando zum Abfragen und zum Speichern von Ganglinien.
|
private boolean |
sendenErlaubt
Sendererlaubnis zum Senden von Gl-Anfragen.
|
private de.bsvrz.dav.daf.main.config.SystemObject |
serverObj
Systemobjekt des Ganglinien-Servers.
|
private long |
timeout
Timeout.
|
private static long |
TIMEOUT
Standard-Timeout fuer Antworten vom Ganglinien-Server.
|
| Modifier | Constructor and Description |
|---|---|
private |
GlSpeicherClient(de.bsvrz.sys.funclib.bitctrl.modell.ObjektFactory objectFactory)
Standardkonstruktor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
dataRequest(de.bsvrz.dav.daf.main.config.SystemObject arg0,
de.bsvrz.dav.daf.main.DataDescription arg1,
byte arg2) |
List<GanglinieMQ> |
getGanglinien(de.bsvrz.dav.daf.main.config.SystemObject mqSysObj)
Fragt saemtliche Ganglinien eines MQ ab (synchron).
|
static GlSpeicherClientInterface |
getInstanz(de.bsvrz.sys.funclib.bitctrl.modell.ObjektFactory objectFactory)
Erfragt die statische Instanz dieser Klasse fuer die uebergebene
DAV-Objektfactory.
|
long |
getTimeout()
Erfragt das aktuelle Timeout auf Anfragen.
|
boolean |
isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject arg0,
de.bsvrz.dav.daf.main.DataDescription arg1) |
void |
setGanglinien(de.bsvrz.dav.daf.main.config.SystemObject mqSysObj,
List<GanglinieMQ> ganglinien)
Setzt (speichert) die Ganglinien eines MQ (synchron).
|
void |
setTimeout(long timeoutInMillis)
Setzt das Timeout auf Anfragen.
|
void |
update(de.bsvrz.dav.daf.main.ResultData[] results) |
private static final int REQ_GETSET
private static final int REQ_DELETE
private static final long TIMEOUT
private static final Map<de.bsvrz.sys.funclib.bitctrl.modell.ObjektFactory,GlSpeicherClient> davZuClientMap
private static long anfrageId
private final de.bsvrz.dav.daf.main.ClientDavInterface dav
private final de.bsvrz.sys.funclib.bitctrl.modell.ObjektFactory objektFactory
private final de.bsvrz.dav.daf.main.DataDescription anfrageDataDescription
private final de.bsvrz.dav.daf.main.config.SystemObject serverObj
private final de.bsvrz.dav.daf.main.config.SystemObject app
private boolean inWait
private de.bsvrz.dav.daf.main.ResultData lastResult
private boolean sendenErlaubt
private long timeout
private GlSpeicherClient(de.bsvrz.sys.funclib.bitctrl.modell.ObjektFactory objectFactory)
throws de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
objectFactory - DAV-Objektfactory.de.bsvrz.dav.daf.main.OneSubscriptionPerSendData - wird weitergereicht.public static final GlSpeicherClientInterface getInstanz(de.bsvrz.sys.funclib.bitctrl.modell.ObjektFactory objectFactory) throws de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
objectFactory - DAV-Objektfactory.de.bsvrz.dav.daf.main.OneSubscriptionPerSendData - wird weitergereicht.public List<GanglinieMQ> getGanglinien(de.bsvrz.dav.daf.main.config.SystemObject mqSysObj) throws de.bsvrz.dav.daf.main.DataNotSubscribedException, de.bsvrz.dav.daf.main.SendSubscriptionNotConfirmed, GlSpeicherServerException, de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
getGanglinien in interface GlSpeicherClientInterfacemqSysObj - das SystemObjekt des MQ.de.bsvrz.dav.daf.main.DataNotSubscribedException - wird weitergereicht.de.bsvrz.dav.daf.main.SendSubscriptionNotConfirmed - wird weitergereicht.GlSpeicherServerException - wird geworfen, wenn auf Serverseite ein Fehler auftritt.de.bsvrz.dav.daf.main.OneSubscriptionPerSendData - wird weitergereicht.public void setGanglinien(de.bsvrz.dav.daf.main.config.SystemObject mqSysObj,
List<GanglinieMQ> ganglinien)
throws de.bsvrz.dav.daf.main.DataNotSubscribedException,
de.bsvrz.dav.daf.main.SendSubscriptionNotConfirmed,
GlSpeicherServerException,
de.bsvrz.dav.daf.main.OneSubscriptionPerSendData
setGanglinien in interface GlSpeicherClientInterfacemqSysObj - das SystemObjekt des MQ, an dem die uebergebenen Ganglinien
gespeichert werden sollen.ganglinien - alle Ganglinien eines MQ. Wird hier null
uebergeben, so werden die Ganglinien am MQ geloescht.de.bsvrz.dav.daf.main.DataNotSubscribedException - wird weitergereicht.de.bsvrz.dav.daf.main.SendSubscriptionNotConfirmed - wird weitergereicht.GlSpeicherServerException - wird geworfen, wenn auf Serverseite ein Fehler auftritt.de.bsvrz.dav.daf.main.OneSubscriptionPerSendData - wird weitergereicht.public void setTimeout(long timeoutInMillis)
setTimeout in interface GlSpeicherClientInterfacetimeoutInMillis - Timeout in Millisekunden.public long getTimeout()
getTimeout in interface GlSpeicherClientInterfacepublic void update(de.bsvrz.dav.daf.main.ResultData[] results)
update in interface de.bsvrz.dav.daf.main.ClientReceiverInterfacepublic void dataRequest(de.bsvrz.dav.daf.main.config.SystemObject arg0,
de.bsvrz.dav.daf.main.DataDescription arg1,
byte arg2)
dataRequest in interface de.bsvrz.dav.daf.main.ClientSenderInterfacepublic boolean isRequestSupported(de.bsvrz.dav.daf.main.config.SystemObject arg0,
de.bsvrz.dav.daf.main.DataDescription arg1)
isRequestSupported in interface de.bsvrz.dav.daf.main.ClientSenderInterfaceCopyright © 2017 BitCtrl Systems GmbH. All rights reserved.