Class LocalConnector

    • Method Detail

      • getTransport

        public java.lang.Object getTransport()
        Returns:
        the underlying socket, channel, buffer etc. for the connector.
      • executeRequest

        public LocalConnector.LocalEndPoint executeRequest​(java.lang.String rawRequest)
        Execute a request and return the EndPoint through which multiple responses can be received or more input provided.
        Parameters:
        rawRequest - the request
        Returns:
        the local endpoint
      • accept

        protected void accept​(int acceptorID)
                       throws java.lang.InterruptedException
        Specified by:
        accept in class AbstractConnector
        Throws:
        java.lang.InterruptedException
      • getResponse

        public java.nio.ByteBuffer getResponse​(java.nio.ByteBuffer requestsBuffer)
                                        throws java.lang.Exception
        Get a single response using a parser to search for the end of the message.
        Parameters:
        requestsBuffer - The request to send
        Returns:
        ByteBuffer containing response or null.
        Throws:
        java.lang.Exception - If there is a problem
      • getResponse

        public java.nio.ByteBuffer getResponse​(java.nio.ByteBuffer requestBuffer,
                                               long time,
                                               java.util.concurrent.TimeUnit unit)
                                        throws java.lang.Exception
        Get a single response using a parser to search for the end of the message.
        Parameters:
        requestBuffer - The request to send
        time - The time to wait
        unit - The units of the wait
        Returns:
        ByteBuffer containing response or null.
        Throws:
        java.lang.Exception - If there is a problem
      • getResponse

        public java.nio.ByteBuffer getResponse​(java.nio.ByteBuffer requestBuffer,
                                               boolean head,
                                               long time,
                                               java.util.concurrent.TimeUnit unit)
                                        throws java.lang.Exception
        Get a single response using a parser to search for the end of the message.
        Parameters:
        requestBuffer - The request to send
        head - True if the response is for a head request
        time - The time to wait
        unit - The units of the wait
        Returns:
        ByteBuffer containing response or null.
        Throws:
        java.lang.Exception - If there is a problem
      • getResponse

        public java.lang.String getResponse​(java.lang.String rawRequest)
                                     throws java.lang.Exception
        Get a single response using a parser to search for the end of the message.
        Parameters:
        rawRequest - The request to send
        Returns:
        ByteBuffer containing response or null.
        Throws:
        java.lang.Exception - If there is a problem
      • getResponse

        public java.lang.String getResponse​(java.lang.String rawRequest,
                                            long time,
                                            java.util.concurrent.TimeUnit unit)
                                     throws java.lang.Exception
        Get a single response using a parser to search for the end of the message.
        Parameters:
        rawRequest - The request to send
        time - The time to wait
        unit - The units of the wait
        Returns:
        ByteBuffer containing response or null.
        Throws:
        java.lang.Exception - If there is a problem
      • getResponse

        public java.lang.String getResponse​(java.lang.String rawRequest,
                                            boolean head,
                                            long time,
                                            java.util.concurrent.TimeUnit unit)
                                     throws java.lang.Exception
        Get a single response using a parser to search for the end of the message.
        Parameters:
        rawRequest - The request to send
        head - True if the response is for a head request
        time - The time to wait
        unit - The units of the wait
        Returns:
        ByteBuffer containing response or null.
        Throws:
        java.lang.Exception - If there is a problem