1 package org.apache.mina.protocol.io;
2
3 import org.apache.mina.protocol.ProtocolSession;
4 import org.apache.mina.protocol.ProtocolSessionManager;
5 import org.apache.mina.protocol.ProtocolSessionManagerFilterChain;
6 import org.apache.mina.util.Queue;
7
8 class IoProtocolSessionManagerFilterChain extends ProtocolSessionManagerFilterChain {
9
10 IoProtocolSessionManagerFilterChain( ProtocolSessionManager manager )
11 {
12 super( manager );
13 }
14
15 protected void doWrite( ProtocolSession session, Object message )
16 {
17 IoProtocolSession s = ( IoProtocolSession ) session;
18 Queue writeQueue = s.writeQueue;
19 synchronized( writeQueue )
20 {
21 writeQueue.push( message );
22 }
23
24 s.shAdapter.doWrite( s.session );
25 }
26 }