Class DefaultIoSessionDataStructureFactory

java.lang.Object

org.apache.mina.core.session.DefaultIoSessionDataStructureFactory

All Implemented Interfaces:

IoSessionDataStructureFactory

public class DefaultIoSessionDataStructureFactory
extends Object
implements IoSessionDataStructureFactory

The default IoSessionDataStructureFactory implementation that creates a new HashMap-based IoSessionAttributeMap instance and a new synchronized ConcurrentLinkedQueue instance per IoSession.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap
private static class	DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue

Constructor Summary

Constructors

Constructor	Description
DefaultIoSessionDataStructureFactory()

Method Summary

Modifier and Type	Method	Description
IoSessionAttributeMap	getAttributeMap(IoSession session)
WriteRequestQueue	getWriteRequestQueue(IoSession session)

Methods inherited from class Object

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

Constructor Details

DefaultIoSessionDataStructureFactory

public DefaultIoSessionDataStructureFactory()

Method Details

getAttributeMap

public IoSessionAttributeMap getAttributeMap(IoSession session)
                                      throws Exception

Specified by:

getAttributeMap in interface IoSessionDataStructureFactory

Parameters:

session - The session for which we want the Attribute Map

Returns:

an IoSessionAttributeMap which is going to be associated with the specified session. Please note that the returned implementation must be thread-safe.

Throws:

Exception - If an error occured while retrieving the map

getWriteRequestQueue

public WriteRequestQueue getWriteRequestQueue(IoSession session)
                                       throws Exception

Specified by:

getWriteRequestQueue in interface IoSessionDataStructureFactory

Parameters:

session - The session for which we want the WriteRequest queue

Returns:

an WriteRequest which is going to be associated with the specified session. Please note that the returned implementation must be thread-safe and robust enough to deal with various messages types (even what you didn't expect at all), especially when you are going to implement a priority queue which involves Comparator.

Throws:

Exception - If an error occured while retrieving the queue