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 Object implements WriteRequestQueue

  • Field Details

  • Constructor Details

    • DefaultWriteRequestQueue

      private DefaultWriteRequestQueue()

  • Method Details

    • 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 String toString()
      Overrides:
      toString in class Object

    • size

      public int size()
      Specified by:
      size in interface WriteRequestQueue
      Returns:
      the number of objects currently stored in the queue.