org.apache.mina.core.session

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.

Author:

Apache MINA Project

Constructor Summary

Constructors

Constructor and Description
DefaultIoSessionDataStructureFactory()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultIoSessionDataStructureFactory

public DefaultIoSessionDataStructureFactory()

Method Detail

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