public class DefaultIoSessionDataStructureFactory extends java.lang.Object implements IoSessionDataStructureFactory
IoSessionDataStructureFactory implementation
that creates a new HashMap-based IoSessionAttributeMap
instance and a new synchronized ConcurrentLinkedQueue instance per
IoSession.| Constructor and Description |
|---|
DefaultIoSessionDataStructureFactory() |
| Modifier and Type | Method and Description |
|---|---|
IoSessionAttributeMap |
getAttributeMap(IoSession session)
Returns an
IoSessionAttributeMap which is going to be associated
with the specified session. |
WriteRequestQueue |
getWriteRequestQueue(IoSession session)
Returns an
WriteRequest which is going to be associated with
the specified session. |
public DefaultIoSessionDataStructureFactory()
public IoSessionAttributeMap getAttributeMap(IoSession session) throws java.lang.Exception
IoSessionDataStructureFactoryIoSessionAttributeMap which is going to be associated
with the specified session. Please note that the returned
implementation must be thread-safe.getAttributeMap in interface IoSessionDataStructureFactoryjava.lang.Exceptionpublic WriteRequestQueue getWriteRequestQueue(IoSession session) throws java.lang.Exception
IoSessionDataStructureFactoryWriteRequest 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.getWriteRequestQueue in interface IoSessionDataStructureFactoryjava.lang.Exception