Class DavRequester

java.lang.Object
de.bsvrz.dav.daf.main.DavRequester
Direct Known Subclasses:
ClientDavRequester

public abstract class DavRequester extends 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:
    • SUBSCRIBE_TRANSMITTER_DRAIN

      protected static final int SUBSCRIBE_TRANSMITTER_DRAIN
      See Also:
    • SUBSCRIPTION_INFO

      protected static final int SUBSCRIPTION_INFO
      See Also:
    • APP_SUBSCRIPTION_INFO

      protected static final int APP_SUBSCRIPTION_INFO
      See Also:
    • ANSWER_OK

      protected static final int ANSWER_OK
      See Also:
    • ANSWER_ERROR

      protected static final int ANSWER_ERROR
      See Also:
    • _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, String errorString, SystemObject senderObject) throws IOException
      Sendet eine Anfrage mit einer Fehlernachricht
      Parameters:
      target - Ziel-Systemobjekt
      requestId - Anfrage-ID
      errorString - Fehlermeldung
      senderObject - Eigenes Systemobjekt
      Throws:
      IOException
    • sendError

      protected void sendError(long target, long requestId, String errorString, SystemObject senderObject) throws IOException
      Throws:
      IOException
    • sendBytes

      protected void sendBytes(SystemObject target, long requestId, long answerKind, byte[] data, SystemObject senderObject) throws 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:
      IOException
    • sendBytes

      protected void sendBytes(long target, long requestId, long answerKind, byte[] data, SystemObject senderObject) throws IOException
      Throws:
      IOException