org.restlet.ext.nio.internal.way

Class HttpServerOutboundWay

java.lang.Object

org.restlet.ext.nio.internal.way.Way

org.restlet.ext.nio.internal.way.OutboundWay

org.restlet.ext.nio.internal.way.ServerOutboundWay

org.restlet.ext.nio.internal.way.HttpServerOutboundWay

All Implemented Interfaces:

BufferProcessor, CompletionListener, SelectionListener

Direct Known Subclasses:

HttpsServerOutboundWay

public class HttpServerOutboundWay
extends ServerOutboundWay

HTTP server outbound way.

Author:

Jerome Louvel

Constructor Summary

Constructors

Constructor and Description
HttpServerOutboundWay(Connection<Server> connection, int bufferSize) Constructor.

Method Summary

Modifier and Type	Method and Description
void	clear() Recycles the way so it can be reused.
int	getLoadScore() Returns a score representing the way load and that could be compared with other ways of the same parent connection.
Queue<Response>	getMessages() Returns the queue of messages.
void	handle(Response response) Add a message to the outbound way.
boolean	isEmpty() Indicates if the way is empty.
void	onError(Status status) Called on error.
void	onMessageCompleted(boolean endDetected) Callback method invoked when the current message has been completely received or sent.
void	onTimeOut() Called back by the controller when an IO time out has been detected.
void	updateState() Updates the way IO and message states.

Methods inherited from class org.restlet.ext.nio.internal.way.ServerOutboundWay

addHeaders, addResponseHeaders, getActualMessage, getConnection, writeStartLine

Methods inherited from class org.restlet.ext.nio.internal.way.OutboundWay

addEntityHeaders, addGeneralHeaders, flushBuffer, getEntityChannel, getEntityChannelType, getEntityFileChannel, getEntityInterestOps, getEntitySelectableChannel, getEntitySelectionKey, getHeaderIndex, getInterestOperations, getVersion, hasIoInterest, onDrain, onFill, onFillEof, onHeadersCompleted, onPostProcessing, processIoBuffer, setEntityChannel, setEntityChannelType, setEntitySelectionKey, setHeaderIndex, shouldBeChunked, writeLine

Methods inherited from class org.restlet.ext.nio.internal.way.Way

canLoop, clearLineBuilder, couldDrain, couldFill, getBuffer, getHeaders, getHelper, getIoState, getLineBuilder, getLineBuilderState, getLogger, getMessage, getMessageState, getRegistration, isAvailable, onClosed, onSelected, postProcess, preProcess, setHeaders, setIoState, setLineBuilderState, setMessage, setMessageState, setRegistration, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpServerOutboundWay

public HttpServerOutboundWay(Connection<Server> connection,
                             int bufferSize)

Constructor.

Parameters:

connection - The parent connection.

bufferSize - The byte buffer size.

Method Detail

clear

public void clear()

Description copied from class: Way

Recycles the way so it can be reused. Typically invoked by a connection pool.

Overrides:

clear in class OutboundWay

getLoadScore

public int getLoadScore()

Description copied from class: Way

Returns a score representing the way load and that could be compared with other ways of the same parent connection.

Overrides:

getLoadScore in class Way

Returns:

A score representing the way load.

getMessages

public Queue<Response> getMessages()

Returns the queue of messages.

Returns:

The queue of messages.

handle

public void handle(Response response)

Description copied from class: OutboundWay

Add a message to the outbound way.

Specified by:

handle in class OutboundWay

isEmpty

public boolean isEmpty()

Description copied from class: Way

Indicates if the way is empty.

Overrides:

isEmpty in class Way

Returns:

True if the way is empty.

onError

public void onError(Status status)

Description copied from class: Way

Called on error.

Overrides:

onError in class OutboundWay

Parameters:

status - The error status.

onMessageCompleted

public void onMessageCompleted(boolean endDetected)
                        throws IOException

Description copied from class: Way

Callback method invoked when the current message has been completely received or sent.

Specified by:

onMessageCompleted in interface CompletionListener

Overrides:

onMessageCompleted in class ServerOutboundWay

Parameters:

endDetected - Indicates if the end of the socket channel was detected.

Throws:

IOException

onTimeOut

public void onTimeOut()

Description copied from class: Way

Called back by the controller when an IO time out has been detected.

Overrides:

onTimeOut in class OutboundWay

updateState

public void updateState()

Description copied from class: Way

Updates the way IO and message states.

Overrides:

updateState in class OutboundWay