Class TargetRequest


  • public class TargetRequest
    extends Object
    This is a class for representing a request to be sent to a target.
    • Constructor Detail

      • TargetRequest

        public TargetRequest​(TargetConfiguration targetConfiguration,
                             org.apache.http.conn.routing.HttpRoute route,
                             URL url,
                             String method,
                             boolean hasEntityBody)
        Create a target request.
        Parameters:
        targetConfiguration - the configuration of the sender
        url - the url to be used
        method - the HTTP method
        hasEntityBody - weather request has an entity body
      • TargetRequest

        public TargetRequest​(TargetConfiguration targetConfiguration,
                             org.apache.http.conn.routing.HttpRoute route,
                             String method,
                             URL url,
                             boolean hasEntityBody)
    • Method Detail

      • connect

        public void connect​(Pipe pipe)
      • start

        public void start​(org.apache.http.nio.NHttpClientConnection conn)
                   throws IOException,
                          org.apache.http.HttpException
        Throws:
        IOException
        org.apache.http.HttpException
      • write

        public int write​(org.apache.http.nio.NHttpClientConnection conn,
                         org.apache.http.nio.ContentEncoder encoder)
                  throws IOException
        Consume the data from the pipe and write it to the wire.
        Parameters:
        conn - the connection to the target
        encoder - encoder for writing the message through
        Returns:
        number of bytes written
        Throws:
        IOException - if an error occurs
      • hasEntityBody

        public boolean hasEntityBody()
      • getUrl

        public URL getUrl()
      • setHasEntityBody

        public void setHasEntityBody​(boolean hasEntityBody)
      • addHeader

        public void addHeader​(String name,
                              String value)
      • getMethod

        public String getMethod()
      • setChunk

        public void setChunk​(boolean chunk)
      • setPort

        public void setPort​(int port)
      • setFullUrl

        public void setFullUrl​(boolean fullUrl)
      • setVersion

        public void setVersion​(org.apache.http.ProtocolVersion version)
      • setKeepAlive

        public void setKeepAlive​(boolean keepAlive)
      • getRequest

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

        public org.apache.http.conn.routing.HttpRoute getRoute()
      • getPipe

        public Pipe getPipe()