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 GlSpeicherClientInterface
mqSysObj
- 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 GlSpeicherClientInterface
mqSysObj
- 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 GlSpeicherClientInterface
timeoutInMillis
- Timeout in Millisekunden.public long getTimeout()
getTimeout
in interface GlSpeicherClientInterface
public void update(de.bsvrz.dav.daf.main.ResultData[] results)
update
in interface de.bsvrz.dav.daf.main.ClientReceiverInterface
public 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.ClientSenderInterface
public 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.ClientSenderInterface
Copyright © 2017 BitCtrl Systems GmbH. All rights reserved.