com.taobao.metamorphosis.server.store
接口 MessageSet

所有已知实现类:
FileMessageSet

public interface MessageSet

消息集合

作者:
boyan

方法摘要
 long append(ByteBuffer buff)
           
 void flush()
           
 long getMessageCount()
           
 void read(ByteBuffer bf)
           
 void read(ByteBuffer bf, long offset)
           
 MessageSet slice(long offset, long limit)
           
 void write(GetCommand getCommand, SessionContext ctx)
           
 

方法详细信息

slice

MessageSet slice(long offset,
                 long limit)
                 throws IOException
抛出:
IOException

write

void write(GetCommand getCommand,
           SessionContext ctx)

append

long append(ByteBuffer buff)
            throws IOException
抛出:
IOException

flush

void flush()
           throws IOException
抛出:
IOException

read

void read(ByteBuffer bf,
          long offset)
          throws IOException
抛出:
IOException

read

void read(ByteBuffer bf)
          throws IOException
抛出:
IOException

getMessageCount

long getMessageCount()


Copyright © 2010–2013. All rights reserved.