Class SourceRequest


  • public class SourceRequest
    extends Object
    Represents a Http Request.
    • Constructor Detail

      • SourceRequest

        public SourceRequest​(SourceConfiguration sourceConfiguration,
                             org.apache.http.HttpRequest request,
                             org.apache.http.nio.NHttpServerConnection conn)
    • Method Detail

      • start

        public void start​(org.apache.http.nio.NHttpServerConnection conn)
                   throws IOException,
                          org.apache.http.HttpException
        Start processing the request by connecting the pipe if this request has an entity body.
        Parameters:
        conn - connection
        Throws:
        IOException - if an error occurs
        org.apache.http.HttpException - if an error occurs
      • read

        public int read​(org.apache.http.nio.NHttpServerConnection conn,
                        org.apache.http.nio.ContentDecoder decoder)
                 throws IOException
        Produce the content in to the pipe.
        Parameters:
        conn - the connection
        decoder - content decoder
        Returns:
        number of bytes read
        Throws:
        IOException - if an error occurs
      • getUri

        public String getUri()
      • getMethod

        public String getMethod()
      • getExcessHeaders

        public Map getExcessHeaders()
      • addExcessHeader

        public void addExcessHeader​(org.apache.http.Header h)
      • getPipe

        public Pipe getPipe()
      • getConnection

        public org.apache.http.nio.NHttpServerConnection getConnection()
      • getVersion

        public org.apache.http.ProtocolVersion getVersion()
      • getRequest

        public org.apache.http.HttpRequest getRequest()
      • isEntityEnclosing

        public boolean isEntityEnclosing()