MsgIterator.java 文件源码

/** 判断是否有下一条消息
 * @return */
public boolean hasNext() throws MsgTimeoutException{
    try {
        return iter.hasNext();
    } catch (ConsumerTimeoutException ex) {
        // 超时并不意味着出错，只是暂时没有消息
        throw new MsgTimeoutException(ex);
    }
}