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 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

      protected final ClientDavConnection _connection
    • _attributeGroup

      protected final AttributeGroup _attributeGroup
    • _receiveAspect

      protected final Aspect _receiveAspect
    • _sendAspect

      protected final Aspect _sendAspect
  • Constructor Details

    • 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 Details

    • 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