Package org.apache.synapse.transport.passthru

Class TargetRequest

java.lang.Object
org.apache.synapse.transport.passthru.TargetRequest
public class TargetRequest extends Object
This is a class for representing a request to be sent to a target.

  • Constructor Details

    • 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 Details

    • 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

    • copyAndWrite

      public ByteBuffer copyAndWrite(org.apache.http.nio.NHttpClientConnection conn, org.apache.http.nio.ContentEncoder encoder) throws IOException
      Same as write(org.apache.http.nio.NHttpClientConnection, org.apache.http.nio.ContentEncoder) but gives out the data consumed from the pipe.
      Parameters:
      conn - the connection to the target
      encoder - encoder for writing the message through
      Returns:
      data consumed
      Throws:
      IOException - if an error occurs

    • hasEntityBody

      public boolean hasEntityBody()

    • getUrl

      public URL getUrl()

    • setHasEntityBody

      public void setHasEntityBody(boolean hasEntityBody)

    • getHeaders

      public Map<String,LinkedHashSet<String>> getHeaders()

    • 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()