com.taobao.metamorphosis.consumer
类 MessageIterator

java.lang.Object
  com.taobao.metamorphosis.consumer.MessageIterator

public class MessageIterator
extends Object

消息迭代器，解析传输过来的数据

作者：

boyan

构造方法摘要

MessageIterator(String topic, byte[] data)

方法摘要

boolean	equals(Object obj)
ByteBuffer	getCurrentMsgBuf()
int	getDataLength()
int	getOffset() 返回当前迭代的偏移量，不包括发起请求的偏移量在内
Message	getPrevMessage()
int	hashCode()
boolean	hasNext() 当还有消息的时候返回true
Message	next() 返回下一个消息
void	remove()
void	setOffset(int offset)

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

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

构造方法详细信息

MessageIterator

public MessageIterator(String topic,
                       byte[] data)

方法详细信息

getCurrentMsgBuf

public ByteBuffer getCurrentMsgBuf()

getDataLength

public int getDataLength()

setOffset

public void setOffset(int offset)

getPrevMessage

public Message getPrevMessage()

getOffset

public int getOffset()

返回当前迭代的偏移量，不包括发起请求的偏移量在内

返回：

hasNext

public boolean hasNext()

当还有消息的时候返回true

返回：

next

public Message next()
             throws InvalidMessageException

返回下一个消息

返回：

抛出：

InvalidMessageException

hashCode

public int hashCode()

覆盖：

类 Object 中的 hashCode

equals

public boolean equals(Object obj)

覆盖：

类 Object 中的 equals

remove

public void remove()