public MessageSet read ( long readOffset , long size ) throws IOException { return new FileMessageSet ( channel , this . offset + readOffset , // Math . min ( this . offset + readOffset + size , highWaterMark ( ) ) , false , new AtomicBoolean ( false ) ) ; }
read message from file