Class TransactionProcessor

    • Constructor Detail

      • TransactionProcessor

        public TransactionProcessor()
    • Method Detail

      • isRequestURIAccepted

        public java.lang.Object isRequestURIAccepted​(IWebSocketComm comm,
                                                     java.lang.String uri,
                                                     java.util.Map<java.lang.String,​java.util.List<java.lang.String>> headerFields)
        Called to check if a request URI can be accepted.
        Specified by:
        isRequestURIAccepted in interface WebSocketAcceptor
        Parameters:
        comm - The WebSocket communication instance.
        uri - The request URI, formatted as e.g. "/something/more.ws?query-params".
        headerFields - HTTP header fields.
        Returns:
        Object an object that is attached to the TransactionComm instance, or null if the URI is not accepted.
      • onCommData

        public void onCommData​(TransactionComm comm,
                               ReadTransaction trans,
                               int size)
        Called when the communication link has received data.
        Specified by:
        onCommData in interface TransactionCommListener
        Parameters:
        comm - The socket communication instance.
        trans - The transaction received.
        size - The size of the data received, as it may have been uncompressed.
      • onCommHeartBeat

        public void onCommHeartBeat​(TransactionComm comm,
                                    long duration)
        Called when a heart-beat frame is received.
        Specified by:
        onCommHeartBeat in interface TransactionCommListener
        Parameters:
        comm - The transaction communication instance.
        duration - Duration of the PING-PONG message exchange in milliseconds.
      • onCommTimeout

        public void onCommTimeout​(TransactionComm comm,
                                  boolean isReadTimeout)
        Called when the communication link has timed out on a read or write operation.
        Specified by:
        onCommTimeout in interface TransactionCommListener
        Parameters:
        comm - The transaction communication instance.
        isReadTimeout - Flag indicating read timeout when true, false indicates write timeout.
      • onCommError

        public void onCommError​(TransactionComm comm,
                                java.lang.Throwable e)
        Called when the communication link is closed.
        Specified by:
        onCommError in interface TransactionCommListener
        Parameters:
        comm - The socket communication instance.
        e - The exception.
      • onCommClosed

        public void onCommClosed​(TransactionComm comm,
                                 int code,
                                 java.lang.String reason)
        Called when the communication link is closed.
        Specified by:
        onCommClosed in interface TransactionCommListener
        Parameters:
        comm - The socket communication instance.