Class 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.
    • Constructor Detail

      • DavRequester

        public DavRequester​(ClientDavConnection connection,
                            Aspect sendAspect,
                            Aspect receiveAspect)
        Erzeugt einen neuen DavRequester
        Parameters:
        connection - Verbindung zum Datenverteiler
        sendAspect - Sende-Aspekt
        receiveAspect - 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-Systemobjekt
        requestId - Anfrage-ID
        errorString - Fehlermeldung
        senderObject - 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-Systemobjekt
        requestId - Anfrage-ID
        answerKind - Nachrichtentyp
        data - Daten
        senderObject - 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