Field Detail

• cachingForRetransmission

  protected boolean cachingForRetransmission

  This boolean is true if the request must be cached.

• chunking

  protected final boolean chunking

  If we are going to be chunking, we won't flush till close which causes new chunks, small network packets, etc..

• cachedStream

  protected CacheAndWriteOutputStream cachedStream

  This field contains the output stream with which we cache the request. It maybe null if we are not caching.

• outMessage

  protected Message outMessage

• conduitName

  protected String conduitName

• url

  protected URI url

Constructor Detail

• HTTPConduit.WrappedOutputStream

  protected HTTPConduit.WrappedOutputStream(Message outMessage,
                                 boolean possibleRetransmit,
                                 boolean isChunking,
                                 int chunkThreshold,
                                 String conduitName,
                                 URI url)

• HTTPConduit.WrappedOutputStream

  protected HTTPConduit.WrappedOutputStream(HTTPConduit.WrappedOutputStream wos)

Method Detail

• thresholdNotReached

  public void thresholdNotReached()

  Specified by:

  thresholdNotReached in class AbstractThresholdOutputStream

• setupWrappedStream

  protected abstract void setupWrappedStream()
                                      throws IOException

  Throws:

  IOException

• getHttpsURLConnectionInfo

  protected abstract HttpsURLConnectionInfo getHttpsURLConnectionInfo()
                                                               throws IOException

  Throws:

  IOException

• setProtocolHeaders

  protected abstract void setProtocolHeaders()
                                      throws IOException

  Throws:

  IOException

• setFixedLengthStreamingMode

  protected abstract void setFixedLengthStreamingMode(int i)

• getResponseCode

  protected abstract int getResponseCode()
                                  throws IOException

  Throws:

  IOException

• getResponseMessage

  protected abstract String getResponseMessage()
                                        throws IOException

  Throws:

  IOException

• updateResponseHeaders

  protected abstract void updateResponseHeaders(Message inMessage)
                                         throws IOException

  Throws:

  IOException

• handleResponseAsync

  protected abstract void handleResponseAsync()
                                       throws IOException

  Throws:

  IOException

• closeInputStream

  protected abstract void closeInputStream()
                                    throws IOException

  Throws:

  IOException

• usingProxy

  protected abstract boolean usingProxy()

• getInputStream

  protected abstract InputStream getInputStream()
                                         throws IOException

  Throws:

  IOException

• getPartialResponse

  protected abstract InputStream getPartialResponse()
                                             throws IOException

  Throws:

  IOException

• setupNewConnection

  protected abstract void setupNewConnection(String newURL)
                                      throws IOException

  Throws:

  IOException

• retransmitStream

  protected abstract void retransmitStream()
                                    throws IOException

  Throws:

  IOException

• updateCookiesBeforeRetransmit

  protected abstract void updateCookiesBeforeRetransmit()
                                                 throws IOException

  Throws:

  IOException

• handleNoOutput

  protected void handleNoOutput()
                         throws IOException

  Throws:

  IOException

• handleResponseOnWorkqueue

  protected void handleResponseOnWorkqueue(boolean allowCurrentThread,
                               boolean forceWQ)
                                    throws IOException

  Throws:

  IOException

• retransmit

  protected void retransmit(String newURL)
                     throws IOException

  Throws:

  IOException

• onFirstWrite

  protected void onFirstWrite()
                       throws IOException

  Perform any actions required on stream flush (freeze headers, reset output stream ... etc.)

  Overrides:

  onFirstWrite in class AbstractWrappedOutputStream

  Throws:

  IOException

• getMethod

  protected String getMethod()

• handleHeadersTrustCaching

  protected void handleHeadersTrustCaching()
                                    throws IOException

  Throws:

  IOException

• close

  public void close()
             throws IOException

  Perform any actions required on stream closure (handle response etc.)

  Specified by:

  close in interface Closeable

  Specified by:

  close in interface AutoCloseable

  Overrides:

  close in class AbstractThresholdOutputStream

  Throws:

  IOException

• handleRetransmits

  protected void handleRetransmits()
                            throws IOException

  This procedure handles all retransmits, if any.

  Throws:

  IOException

• processRetransmit

  protected boolean processRetransmit()
                               throws IOException

  This function processes any retransmits at the direction of redirections or "unauthorized" responses.

  Returns:

  true if there was a retransmit

  Throws:

  IOException

• redirectRetransmit

  protected boolean redirectRetransmit()
                                throws IOException

  Throws:

  IOException

• authorizationRetransmit

  protected boolean authorizationRetransmit()
                                     throws IOException

  This method performs a retransmit for authorization information.

  Parameters:

  connection - The currently active connection.

  message - The outbound message.

  cachedStream - The cached request.

  Returns:

  A new connection if retransmitted. If not retransmitted then this method returns the same connection.

  Throws:

  IOException

• handleResponse

  protected void handleResponse()
                         throws IOException

  This procedure is called on the close of the output stream so we are ready to handle the response from the connection. We may retransmit until we finally get a response.

  Throws:

  IOException

• handleResponseInternal

  protected void handleResponseInternal()
                                 throws IOException

  Throws:

  IOException

• propagateConduit

  protected void propagateConduit(Exchange exchange,
                      Message in)

• handleHttpRetryException

  protected void handleHttpRetryException(HttpRetryException e)
                                   throws IOException

  Throws:

  IOException

• makeTrustDecision

  protected void makeTrustDecision()
                            throws IOException

  This call must take place before anything is written to the URLConnection. The URLConnection.connect() will be called in order to get the connection information. This method is invoked just after setURLRequestHeaders() from the WrappedOutputStream before it writes data to the URLConnection. If trust cannot be established the Trust Decider implemenation throws an IOException.

  Parameters:

  message - The message being sent.

  Throws:

  IOException - This exception is thrown if trust cannot be established by the configured MessageTrustDecider.

  See Also:

  MessageTrustDecider