Interface Connection

    • Method Detail

      • getConnector

        Connector getConnector()
        Returns:
        the connector that created this connection.
      • dispatchSync

        void dispatchSync​(Command message)
        Sends a message to the client.
        Parameters:
        message - the message to send to the client.
      • dispatchAsync

        void dispatchAsync​(Command command)
        Sends a message to the client.
        Parameters:
        command -
      • service

        Response service​(Command command)
        Services a client command and submits it to the broker.
        Parameters:
        command -
        Returns:
        Response
      • serviceException

        void serviceException​(Throwable error)
        Handles an unexpected error associated with a connection.
        Parameters:
        error -
      • isSlow

        boolean isSlow()
        Returns:
        true if the Connection is slow
      • isBlocked

        boolean isBlocked()
        Returns:
        if after being marked, the Connection is still writing
      • isConnected

        boolean isConnected()
        Returns:
        true if the Connection is connected
      • isActive

        boolean isActive()
        Returns:
        true if the Connection is active
      • getDispatchQueueSize

        int getDispatchQueueSize()
        Returns the number of messages to be dispatched to this connection
      • isManageable

        boolean isManageable()
        Returns:
        true if the Connection will process control commands
      • getRemoteAddress

        String getRemoteAddress()
        Returns:
        the source address for this connection
      • serviceExceptionAsync

        void serviceExceptionAsync​(IOException e)
      • getConnectionId

        String getConnectionId()
      • isNetworkConnection

        boolean isNetworkConnection()
        return true if a network connection
        Returns:
        if this is a network connection
      • isFaultTolerantConnection

        boolean isFaultTolerantConnection()
        Returns:
        true if a fault tolerant connection
      • getActiveTransactionCount

        int getActiveTransactionCount()
        Returns the number of active transactions established on this Connection.
        Returns:
        the number of active transactions established on this Connection..
      • getOldestActiveTransactionDuration

        Long getOldestActiveTransactionDuration()
        Returns the number of active transactions established on this Connection.
        Returns:
        the number of active transactions established on this Connection..