Class AbstractStreamWriteFilter<T>

java.lang.Object

org.apache.mina.core.filterchain.IoFilterAdapter

org.apache.mina.filter.stream.AbstractStreamWriteFilter<T>

Type Parameters:

T - The type of Stream

All Implemented Interfaces:

IoFilter

Direct Known Subclasses:

FileRegionWriteFilter, StreamWriteFilter

public abstract class AbstractStreamWriteFilter<T>
extends IoFilterAdapter

Filter implementation which makes it possible to write Stream objects directly using IoSession.write(Object).

Nested Class Summary

Nested classes/interfaces inherited from interface IoFilter

IoFilter.NextFilter

Field Summary

Fields

Modifier and Type	Field	Description
protected static final AttributeKey	CURRENT_STREAM	The attribute name used when binding the streaming object to the session.
protected static final AttributeKey	CURRENT_WRITE_REQUEST
static final int	DEFAULT_STREAM_BUFFER_SIZE	The default buffer size this filter uses for writing.
protected static final AttributeKey	WRITE_REQUEST_QUEUE
private int	writeBufferSize

Constructor Summary

Constructors

Constructor	Description
AbstractStreamWriteFilter()

Method Summary

Modifier and Type	Method	Description
void	filterWrite(IoFilter.NextFilter nextFilter, IoSession session, WriteRequest writeRequest)	Filters IoSession.write(Object) method invocation.
protected abstract Class<T>	getMessageClass()
protected abstract IoBuffer	getNextBuffer(T message)
int	getWriteBufferSize()
private Queue<WriteRequest>	getWriteRequestQueue(IoSession session)
void	messageSent(IoFilter.NextFilter nextFilter, IoSession session, WriteRequest writeRequest)	Filters IoHandler.messageSent(IoSession,Object) event.
void	onPreAdd(IoFilterChain parent, String name, IoFilter.NextFilter nextFilter)	Invoked before this filter is added to the specified parent.
private Queue<WriteRequest>	removeWriteRequestQueue(IoSession session)
void	setWriteBufferSize(int writeBufferSize)	Sets the size of the write buffer in bytes.

Methods inherited from class IoFilterAdapter

destroy, event, exceptionCaught, filterClose, init, inputClosed, messageReceived, onPostAdd, onPostRemove, onPreRemove, sessionClosed, sessionCreated, sessionIdle, sessionOpened, toString

Methods inherited from class Object

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

Field Details

DEFAULT_STREAM_BUFFER_SIZE

public static final int DEFAULT_STREAM_BUFFER_SIZE

The default buffer size this filter uses for writing.

See Also:

• Constant Field Values

CURRENT_STREAM

protected static final AttributeKey CURRENT_STREAM

The attribute name used when binding the streaming object to the session.

WRITE_REQUEST_QUEUE

protected static final AttributeKey WRITE_REQUEST_QUEUE

CURRENT_WRITE_REQUEST

protected static final AttributeKey CURRENT_WRITE_REQUEST

writeBufferSize

private int writeBufferSize

Constructor Details

AbstractStreamWriteFilter

public AbstractStreamWriteFilter()

Method Details

onPreAdd

public void onPreAdd(IoFilterChain parent,
 String name,
 IoFilter.NextFilter nextFilter)
              throws Exception

Invoked before this filter is added to the specified parent. Please note that this method can be invoked more than once if this filter is added to more than one parents. This method is not invoked before IoFilter.init() is invoked.

Specified by:

onPreAdd in interface IoFilter

Overrides:

onPreAdd in class IoFilterAdapter

Parameters:

parent - the parent who called this method

name - the name assigned to this filter

nextFilter - the IoFilter.NextFilter for this filter. You can reuse this object until this filter is removed from the chain.

Throws:

Exception - If an error occurred while processing the event

filterWrite

public void filterWrite(IoFilter.NextFilter nextFilter,
 IoSession session,
 WriteRequest writeRequest)
                 throws Exception

Filters IoSession.write(Object) method invocation.

Specified by:

filterWrite in interface IoFilter

Overrides:

filterWrite in class IoFilterAdapter

Parameters:

nextFilter - the IoFilter.NextFilter for this filter. You can reuse this object until this filter is removed from the chain.

session - The IoSession which has to process this invocation

writeRequest - The WriteRequest to process

Throws:

Exception - If an error occurred while processing the event

getMessageClass

protected abstract Class<T> getMessageClass()

getWriteRequestQueue

private Queue<WriteRequest> getWriteRequestQueue(IoSession session)

removeWriteRequestQueue

private Queue<WriteRequest> removeWriteRequestQueue(IoSession session)

messageSent

public void messageSent(IoFilter.NextFilter nextFilter,
 IoSession session,
 WriteRequest writeRequest)
                 throws Exception

Filters IoHandler.messageSent(IoSession,Object) event.

Specified by:

messageSent in interface IoFilter

Overrides:

messageSent in class IoFilterAdapter

Parameters:

nextFilter - the IoFilter.NextFilter for this filter. You can reuse this object until this filter is removed from the chain.

session - The IoSession which has received this event

writeRequest - The WriteRequest that contains the sent message

Throws:

Exception - If an error occurred while processing the event

getWriteBufferSize

public int getWriteBufferSize()

Returns:

the size of the write buffer in bytes. Data will be read from the stream in chunks of this size and then written to the next filter.

setWriteBufferSize

public void setWriteBufferSize(int writeBufferSize)

Sets the size of the write buffer in bytes. Data will be read from the stream in chunks of this size and then written to the next filter.

Parameters:

writeBufferSize - The size of the write buffer

Throws:

IllegalArgumentException - if the specified size is < 1.

getNextBuffer

protected abstract IoBuffer getNextBuffer(T message)
                                   throws IOException

Throws:

IOException