public void add(MessageEvent e){
  m_queue.add(e);
  ByteBuf buf=(ByteBuf)e.getMsg();
  m_bufferSize.addAndGet(buf.readableBytes());
}

public void add ( MessageEvent e ) { m_queue . add ( e ) ; ByteBuf buf = ( ByteBuf ) e . getMsg ( ) ; m_bufferSize . addAndGet ( buf . readableBytes ( ) ) ; }
return true if time to flush else return false
