org.apache.synapse.transport.utils.conn

Class SynapseNHttpClientConnection

java.lang.Object

org.apache.http.impl.nio.NHttpConnectionBase

org.apache.http.impl.nio.DefaultNHttpClientConnection

org.apache.synapse.transport.utils.conn.SynapseNHttpClientConnection

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.http.HttpConnection, org.apache.http.HttpInetConnection, org.apache.http.nio.IOControl, org.apache.http.nio.NHttpClientConnection, org.apache.http.nio.NHttpClientIOTarget, org.apache.http.nio.NHttpConnection, org.apache.http.nio.reactor.SessionBufferStatus, org.apache.http.nio.reactor.SocketAccessor

Direct Known Subclasses:

LoggingNHttpClientConnection

public class SynapseNHttpClientConnection
extends org.apache.http.impl.nio.DefaultNHttpClientConnection

An extension of the DefaultNHttpClientConnection class, that has some additional stuff related to synapse NHttp transport implementation

Field Summary

Fields inherited from class org.apache.http.impl.nio.DefaultNHttpClientConnection

requestWriter, responseParser

Fields inherited from class org.apache.http.impl.nio.NHttpConnectionBase

connMetrics, contentDecoder, contentEncoder, context, hasBufferedInput, hasBufferedOutput, inbuf, incomingContentStrategy, inTransportMetrics, outbuf, outgoingContentStrategy, outTransportMetrics, remote, request, response, session, status

Fields inherited from interface org.apache.http.nio.NHttpConnection

ACTIVE, CLOSED, CLOSING

Constructor Summary

Constructors

Constructor and Description

SynapseNHttpClientConnection(org.apache.http.nio.reactor.IOSession session, int bufferSize, int fragmentSizeHint, org.apache.http.nio.util.ByteBufferAllocator allocator, CharsetDecoder charDecoder, CharsetEncoder charEncoder, org.apache.http.config.MessageConstraints constraints, org.apache.http.entity.ContentLengthStrategy incomingContentStrategy, org.apache.http.entity.ContentLengthStrategy outgoingContentStrategy, org.apache.http.nio.NHttpMessageWriterFactory<org.apache.http.HttpRequest> requestWriterFactory, org.apache.http.nio.NHttpMessageParserFactory<org.apache.http.HttpResponse> responseParserFactory)

Method Summary

Modifier and Type	Method and Description
void	close()
void	consumeInput(org.apache.http.nio.NHttpClientEventHandler handler)
void	markForRelease() Mark this connection to be released to the pool.
void	produceOutput(org.apache.http.nio.NHttpClientEventHandler handler)
void	shutdown()
void	submitRequest(org.apache.http.HttpRequest request)

Methods inherited from class org.apache.http.impl.nio.DefaultNHttpClientConnection

consumeInput, createRequestWriter, createResponseParser, isRequestSubmitted, onRequestSubmitted, onResponseReceived, produceOutput, resetInput, resetOutput

Methods inherited from class org.apache.http.impl.nio.NHttpConnectionBase

assertNotClosed, bind, createConnectionMetrics, createContentDecoder, createContentEncoder, createIncomingContentStrategy, createOutgoingContentStrategy, createTransportMetrics, getContext, getHttpRequest, getHttpResponse, getLocalAddress, getLocalPort, getMetrics, getRemoteAddress, getRemotePort, getSocket, getSocketTimeout, getStatus, hasBufferedInput, hasBufferedOutput, isOpen, isStale, prepareDecoder, prepareEncoder, requestInput, requestOutput, setSocketTimeout, suspendInput, suspendOutput, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.http.nio.NHttpConnection

getContext, getHttpRequest, getHttpResponse, getStatus

Methods inherited from interface org.apache.http.HttpConnection

getMetrics, getSocketTimeout, isOpen, isStale, setSocketTimeout

Methods inherited from interface org.apache.http.nio.IOControl

requestInput, requestOutput, suspendInput, suspendOutput

Constructor Detail

SynapseNHttpClientConnection

public SynapseNHttpClientConnection(org.apache.http.nio.reactor.IOSession session,
                                    int bufferSize,
                                    int fragmentSizeHint,
                                    org.apache.http.nio.util.ByteBufferAllocator allocator,
                                    CharsetDecoder charDecoder,
                                    CharsetEncoder charEncoder,
                                    org.apache.http.config.MessageConstraints constraints,
                                    org.apache.http.entity.ContentLengthStrategy incomingContentStrategy,
                                    org.apache.http.entity.ContentLengthStrategy outgoingContentStrategy,
                                    org.apache.http.nio.NHttpMessageWriterFactory<org.apache.http.HttpRequest> requestWriterFactory,
                                    org.apache.http.nio.NHttpMessageParserFactory<org.apache.http.HttpResponse> responseParserFactory)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.http.HttpConnection

Overrides:

close in class org.apache.http.impl.nio.NHttpConnectionBase

Throws:

IOException

shutdown

public void shutdown()
              throws IOException

Specified by:

shutdown in interface org.apache.http.HttpConnection

Specified by:

shutdown in interface org.apache.http.nio.IOControl

Overrides:

shutdown in class org.apache.http.impl.nio.NHttpConnectionBase

Throws:

IOException

submitRequest

public void submitRequest(org.apache.http.HttpRequest request)
                   throws IOException,
                          org.apache.http.HttpException

Specified by:

submitRequest in interface org.apache.http.nio.NHttpClientConnection

Overrides:

submitRequest in class org.apache.http.impl.nio.DefaultNHttpClientConnection

Throws:

IOException

org.apache.http.HttpException

consumeInput

public void consumeInput(org.apache.http.nio.NHttpClientEventHandler handler)

Overrides:

consumeInput in class org.apache.http.impl.nio.DefaultNHttpClientConnection

produceOutput

public void produceOutput(org.apache.http.nio.NHttpClientEventHandler handler)

Overrides:

produceOutput in class org.apache.http.impl.nio.DefaultNHttpClientConnection

markForRelease

public void markForRelease()

Mark this connection to be released to the pool.

This needs to be called after finishing work related to a particular request/response, and only when keep-alive is enabled