com.taobao.metamorphosis.server.store
类 FileMessageSet

java.lang.Object
  com.taobao.metamorphosis.server.store.FileMessageSet

所有已实现的接口：

MessageSet, Closeable

public class FileMessageSet
extends Object
implements MessageSet, Closeable

基于文件的消息集合

作者：

boyan

构造方法摘要

FileMessageSet(FileChannel channel)

FileMessageSet(FileChannel channel, long offset, long limit, boolean mutable)

方法摘要

long	append(ByteBuffer buf)
void	close()
void	flush()
long	getMessageCount()
long	getSizeInBytes() Just for test
long	highWaterMark()
boolean	isMutable()
void	read(ByteBuffer bf)
void	read(ByteBuffer bf, long offset)
void	setMutable(boolean mutable)
MessageSet	slice(long offset, long limit) 返回一个MessageSet镜像，指定offset和长度
void	write(GetCommand getCommand, SessionContext ctx)
long	write(WritableByteChannel socketChanel)

从类 java.lang.Object 继承的方法

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

构造方法详细信息

FileMessageSet

public FileMessageSet(FileChannel channel,
                      long offset,
                      long limit,
                      boolean mutable)
               throws IOException

抛出：

IOException

FileMessageSet

public FileMessageSet(FileChannel channel)
               throws IOException

抛出：

IOException

方法详细信息

isMutable

public boolean isMutable()

setMutable

public void setMutable(boolean mutable)

getMessageCount

public long getMessageCount()

指定者：

接口 MessageSet 中的 getMessageCount

highWaterMark

public long highWaterMark()

append

public long append(ByteBuffer buf)
            throws IOException

指定者：

接口 MessageSet 中的 append

抛出：

IOException

flush

public void flush()
           throws IOException

指定者：

接口 MessageSet 中的 flush

抛出：

IOException

getSizeInBytes

public long getSizeInBytes()

Just for test

返回：

slice

public MessageSet slice(long offset,
                        long limit)
                 throws IOException

返回一个MessageSet镜像，指定offset和长度

指定者：

接口 MessageSet 中的 slice

抛出：

IOException

read

public void read(ByteBuffer bf,
                 long offset)
          throws IOException

指定者：

接口 MessageSet 中的 read

抛出：

IOException

read

public void read(ByteBuffer bf)
          throws IOException

指定者：

接口 MessageSet 中的 read

抛出：

IOException

write

public void write(GetCommand getCommand,
                  SessionContext ctx)

指定者：

接口 MessageSet 中的 write

write

public long write(WritableByteChannel socketChanel)
           throws IOException

抛出：

IOException

close

public void close()
           throws IOException

指定者：

接口 Closeable 中的 close

抛出：

IOException