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.ObjectKlasse 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
All Methods Instance Methods Abstract Methods Concrete Methods 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.
-
-
-
Field Detail
-
_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
protected final ClientDavConnection _connection
-
_attributeGroup
protected final AttributeGroup _attributeGroup
-
_receiveAspect
protected final Aspect _receiveAspect
-
_sendAspect
protected final Aspect _sendAspect
-
-
Constructor Detail
-
DavRequester
public DavRequester(ClientDavConnection connection, Aspect sendAspect, Aspect receiveAspect)
Erzeugt einen neuen DavRequester- Parameters:
connection- Verbindung zum DatenverteilersendAspect- Sende-AspektreceiveAspect- Empfangs-Aspekt
-
-
Method Detail
-
subscribeDrain
protected void subscribeDrain(SystemObject object)
Initialisiert den Dav-Requester und meldet sich als Senke für Nachrichten an.- Parameters:
object- Applikation auf die sich angemeldet werden soll
-
onReceive
protected abstract void onReceive(Data data)
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.IOException
Sendet 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.IOException
Sendet 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
-
-