Package de.bsvrz.dav.daf.main
Class DavRequester
java.lang.Object
de.bsvrz.dav.daf.main.DavRequester
- Direct Known Subclasses:
ClientDavRequester
public abstract class DavRequester
extends java.lang.Object
Klasse zur Kommunikation mit dem Datenverteiler. Wird derzeit unter anderem für Anmeldungen von Transaktionsquellen/Senken und für die Abfrage von
Anmeldungen für Debug-Zwecke benutzt.
-
Field Summary
Fields Modifier and Type Field Description protected AttributeGroup_attributeGroupprotected ClientDavConnection_connectionprotected static de.bsvrz.sys.funclib.debug.Debug_debugprotected Aspect_receiveAspectprotected Aspect_sendAspectprotected static intANSWER_ERRORprotected static intANSWER_OKprotected static intAPP_SUBSCRIPTION_INFOprotected static intSUBSCRIBE_TRANSMITTER_DRAINprotected static intSUBSCRIBE_TRANSMITTER_SOURCEprotected static intSUBSCRIPTION_INFO -
Constructor Summary
Constructors Constructor Description DavRequester(ClientDavConnection connection, Aspect sendAspect, Aspect receiveAspect)Erzeugt einen neuen DavRequester -
Method Summary
Modifier and Type Method Description protected abstract voidonReceive(Data data)Wird beim Empfang von Daten aufgerufenprotected voidsendBytes(long target, long requestId, long answerKind, byte[] data, SystemObject senderObject)protected voidsendBytes(SystemObject target, long requestId, long answerKind, byte[] data, SystemObject senderObject)Sendet eine Anfrage mit einem byte-Array als Datenprotected voidsendError(long target, long requestId, java.lang.String errorString, SystemObject senderObject)protected voidsendError(SystemObject target, long requestId, java.lang.String errorString, SystemObject senderObject)Sendet eine Anfrage mit einer Fehlernachrichtprotected voidsubscribeDrain(SystemObject object)Initialisiert den Dav-Requester und meldet sich als Senke für Nachrichten an.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Field Details
-
_debug
protected static final de.bsvrz.sys.funclib.debug.Debug _debug -
SUBSCRIBE_TRANSMITTER_SOURCE
protected static final int SUBSCRIBE_TRANSMITTER_SOURCE- See Also:
- Constant Field Values
-
SUBSCRIBE_TRANSMITTER_DRAIN
protected static final int SUBSCRIBE_TRANSMITTER_DRAIN- See Also:
- Constant Field Values
-
SUBSCRIPTION_INFO
protected static final int SUBSCRIPTION_INFO- See Also:
- Constant Field Values
-
APP_SUBSCRIPTION_INFO
protected static final int APP_SUBSCRIPTION_INFO- See Also:
- Constant Field Values
-
ANSWER_OK
protected static final int ANSWER_OK- See Also:
- Constant Field Values
-
ANSWER_ERROR
protected static final int ANSWER_ERROR- See Also:
- Constant Field Values
-
_connection
-
_attributeGroup
-
_receiveAspect
-
_sendAspect
-
-
Constructor Details
-
DavRequester
Erzeugt einen neuen DavRequester- Parameters:
connection- Verbindung zum DatenverteilersendAspect- Sende-AspektreceiveAspect- Empfangs-Aspekt
-
-
Method Details
-
subscribeDrain
Initialisiert den Dav-Requester und meldet sich als Senke für Nachrichten an.- Parameters:
object- Applikation auf die sich angemeldet werden soll
-
onReceive
Wird beim Empfang von Daten aufgerufen- Parameters:
data- Daten
-
sendError
protected void sendError(SystemObject target, long requestId, java.lang.String errorString, SystemObject senderObject) throws java.io.IOExceptionSendet eine Anfrage mit einer Fehlernachricht- Parameters:
target- Ziel-SystemobjektrequestId- Anfrage-IDerrorString- FehlermeldungsenderObject- Eigenes Systemobjekt- Throws:
java.io.IOException
-
sendError
protected void sendError(long target, long requestId, java.lang.String errorString, SystemObject senderObject) throws java.io.IOException- Throws:
java.io.IOException
-
sendBytes
protected void sendBytes(SystemObject target, long requestId, long answerKind, byte[] data, SystemObject senderObject) throws java.io.IOExceptionSendet eine Anfrage mit einem byte-Array als Daten- Parameters:
target- Ziel-SystemobjektrequestId- Anfrage-IDanswerKind- Nachrichtentypdata- DatensenderObject- Eigenes Systemobjekt- Throws:
java.io.IOException
-
sendBytes
protected void sendBytes(long target, long requestId, long answerKind, byte[] data, SystemObject senderObject) throws java.io.IOException- Throws:
java.io.IOException
-