de.unkrig.commons.net.http

Class HttpClientConnectionHandler

java.lang.Object

de.unkrig.commons.net.http.HttpClientConnectionHandler

All Implemented Interfaces:

de.unkrig.commons.lang.protocol.Stoppable, TcpServer.ConnectionHandler

public class HttpClientConnectionHandler
extends Object
implements TcpServer.ConnectionHandler, de.unkrig.commons.lang.protocol.Stoppable

A container for Servletts that handle requests that are received from a client connection.

Constructor Summary

Constructors

Constructor and Description
HttpClientConnectionHandler()
HttpClientConnectionHandler(Iterable<Servlett> servletts)
HttpClientConnectionHandler(Iterable<Servlett> servletts, String readRequestLogginPrefix, String writeResponseLoggingPrefix)
HttpClientConnectionHandler(Servlett servlett)
HttpClientConnectionHandler(Servlett servlett, String readRequestLogginPrefix, String writeResponseLoggingPrefix)
HttpClientConnectionHandler(String readRequestLogginPrefix, String writeResponseLoggingPrefix)

Method Summary

Modifier and Type	Method and Description
Iterable<Servlett>	getServletts()
void	handleConnection(InputStream in, OutputStream out, InetSocketAddress localSocketAddress, InetSocketAddress remoteSocketAddress, de.unkrig.commons.lang.protocol.Stoppable stoppable) This one is called from the TcpServer.
void	handleConnection(ReadableByteChannel in, WritableByteChannel out, InetSocketAddress localSocketAddress, InetSocketAddress remoteSocketAddress, Multiplexer multiplexer, de.unkrig.commons.lang.protocol.Stoppable stoppable) This one is called from the NioHttpServer.
protected void	processRequests(InputStream in, OutputStream out, de.unkrig.commons.lang.protocol.Stoppable stoppable) Processes HTTP requests from the client until the connection breaks.
void	setServlett(Servlett servlett) Clears the set of currently registerd Servletts and registers the given servlett.
void	setServletts(Iterable<Servlett> servletts) Clears the set of currently registerd Servletts and registers the given servletts.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpClientConnectionHandler

public HttpClientConnectionHandler()

HttpClientConnectionHandler

public HttpClientConnectionHandler(String readRequestLogginPrefix,
                                   String writeResponseLoggingPrefix)

Parameters:

readRequestLogginPrefix - E.g. ">>> "

writeResponseLoggingPrefix - E.g. "<<< "

HttpClientConnectionHandler

public HttpClientConnectionHandler(Servlett servlett)

Parameters:

servlett - See setServlett(Servlett)

HttpClientConnectionHandler

public HttpClientConnectionHandler(Servlett servlett,
                                   String readRequestLogginPrefix,
                                   String writeResponseLoggingPrefix)

Parameters:

servlett - See setServlett(Servlett)

readRequestLogginPrefix - E.g. ">>> "

writeResponseLoggingPrefix - E.g. "<<< "

HttpClientConnectionHandler

public HttpClientConnectionHandler(Iterable<Servlett> servletts)

Parameters:

servletts - See setServletts(Iterable)

HttpClientConnectionHandler

public HttpClientConnectionHandler(Iterable<Servlett> servletts,
                                   String readRequestLogginPrefix,
                                   String writeResponseLoggingPrefix)

Parameters:

servletts - See setServletts(Iterable)

readRequestLogginPrefix - E.g. ">>> "

writeResponseLoggingPrefix - E.g. "<<< "

Method Detail

getServletts

public Iterable<Servlett> getServletts()

Returns:

The Servletts currently registered with this HttpClientConnectionHandler

setServlett

public void setServlett(Servlett servlett)

Clears the set of currently registerd Servletts and registers the given servlett.

setServletts

public void setServletts(Iterable<Servlett> servletts)

Clears the set of currently registerd Servletts and registers the given servletts.

handleConnection

public void handleConnection(InputStream in,
                             OutputStream out,
                             InetSocketAddress localSocketAddress,
                             InetSocketAddress remoteSocketAddress,
                             de.unkrig.commons.lang.protocol.Stoppable stoppable)
                      throws IOException,
                             InvalidHttpMessageException

This one is called from the TcpServer. Override if you want to process the connection before request processing begins.

Specified by:

handleConnection in interface TcpServer.ConnectionHandler

Parameters:

localSocketAddress - Could be examined by implementations that override this method

remoteSocketAddress - Could be examined by implementations that override this method

stoppable - Stopping this will break the connection

Throws:

IOException

InvalidHttpMessageException

handleConnection

public void handleConnection(ReadableByteChannel in,
                             WritableByteChannel out,
                             InetSocketAddress localSocketAddress,
                             InetSocketAddress remoteSocketAddress,
                             Multiplexer multiplexer,
                             de.unkrig.commons.lang.protocol.Stoppable stoppable)
                      throws IOException

This one is called from the NioHttpServer. Override if you want to process the connection before request processing begins.

Parameters:

localSocketAddress - Could be examined by implementations that override this method

remoteSocketAddress - Could be examined by implementations that override this method

stoppable - Stopping this will break the connection

Throws:

IOException

processRequests

protected void processRequests(InputStream in,
                               OutputStream out,
                               de.unkrig.commons.lang.protocol.Stoppable stoppable)
                        throws IOException,
                               InvalidHttpMessageException

Processes HTTP requests from the client until the connection breaks.

Parameters:

stoppable - Stopping this will break the connection

Throws:

IOException

InvalidHttpMessageException

stop

public void stop()

Specified by:

stop in interface de.unkrig.commons.lang.protocol.Stoppable