Package org.apache.mina.core.session

Class DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue

java.lang.Object

org.apache.mina.core.session.DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue

All Implemented Interfaces:

WriteRequestQueue

Enclosing class:

DefaultIoSessionDataStructureFactory

private static class DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue
extends java.lang.Object
implements WriteRequestQueue

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.Queue<WriteRequest>	q	A queue to store incoming write requests

Constructor Summary

Constructors

Modifier	Constructor	Description
private	DefaultWriteRequestQueue()

Method Summary

Modifier and Type	Method	Description
void	clear(IoSession session)	Removes all the requests from this session's queue.
void	dispose(IoSession session)	Disposes any releases associated with the specified session.
boolean	isEmpty(IoSession session)	Tells if the WriteRequest queue is empty or not for a session
void	offer(IoSession session, WriteRequest writeRequest)	Add a new WriteRequest to the session write's queue
WriteRequest	poll(IoSession session)	Get the first request available in the queue for a session.
int	size()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

q

private final java.util.Queue<WriteRequest> q

A queue to store incoming write requests

Constructor Detail

DefaultWriteRequestQueue

private DefaultWriteRequestQueue()

Method Detail

dispose

public void dispose(IoSession session)

Disposes any releases associated with the specified session. This method is invoked on disconnection.

Specified by:

dispose in interface WriteRequestQueue

Parameters:

session - The associated session

clear

public void clear(IoSession session)

Removes all the requests from this session's queue.

Specified by:

clear in interface WriteRequestQueue

Parameters:

session - The associated session

isEmpty

public boolean isEmpty(IoSession session)

Tells if the WriteRequest queue is empty or not for a session

Specified by:

isEmpty in interface WriteRequestQueue

Parameters:

session - The session to check

Returns:

true if the writeRequest is empty

offer

public void offer(IoSession session,
                  WriteRequest writeRequest)

Add a new WriteRequest to the session write's queue

Specified by:

offer in interface WriteRequestQueue

Parameters:

session - The session

writeRequest - The writeRequest to add

poll

public WriteRequest poll(IoSession session)

Get the first request available in the queue for a session.

Specified by:

poll in interface WriteRequestQueue

Parameters:

session - The session

Returns:

The first available request, if any.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

size

public int size()

Specified by:

size in interface WriteRequestQueue

Returns:

the number of objects currently stored in the queue.