提交 2eae25c6 编写于 作者: Y yukon

ROCKETMQ-18 Remove empty class doc.

上级 853b167b
......@@ -22,10 +22,6 @@ import java.util.Map.Entry;
import org.apache.rocketmq.common.message.MessageQueue;
import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
/**
*
*
*/
public class ConsumeStats extends RemotingSerializable {
private HashMap<MessageQueue, OffsetWrapper> offsetTable = new HashMap<MessageQueue, OffsetWrapper>();
private double consumeTps = 0;
......
......@@ -16,10 +16,6 @@
*/
package org.apache.rocketmq.common.admin;
/**
*
*
*/
public class OffsetWrapper {
private long brokerOffset;
private long consumerOffset;
......
......@@ -16,10 +16,6 @@
*/
package org.apache.rocketmq.common.admin;
/**
*
*
*/
public class TopicOffset {
private long minOffset;
private long maxOffset;
......
......@@ -20,10 +20,6 @@ import java.util.HashMap;
import org.apache.rocketmq.common.message.MessageQueue;
import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
/**
*
*
*/
public class TopicStatsTable extends RemotingSerializable {
private HashMap<MessageQueue, TopicOffset> offsetTable = new HashMap<MessageQueue, TopicOffset>();
......
......@@ -19,10 +19,6 @@ package org.apache.rocketmq.common.hook;
import java.nio.ByteBuffer;
/**
*
*
*/
public interface FilterCheckHook {
public String hookName();
......
......@@ -21,10 +21,6 @@ import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
/**
*
*
*/
public class Message implements Serializable {
private static final long serialVersionUID = 8445773977080406428L;
......
......@@ -21,10 +21,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
*
*
*/
public class GetConsumerConnectionListRequestHeader implements CommandCustomHeader {
@CFNotNull
private String consumerGroup;
......
......@@ -28,10 +28,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
*
*
*/
public class QueryCorrectionOffsetHeader implements CommandCustomHeader {
private String filterGroups;
@CFNotNull
......
......@@ -21,10 +21,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
*
*
*/
public class ResetOffsetRequestHeader implements CommandCustomHeader {
@CFNotNull
private String topic;
......
......@@ -180,9 +180,7 @@ public class IndexFile {
}
public boolean isTimeMatched(final long begin, final long end) {
boolean result =
begin < this.indexHeader.getBeginTimestamp() && end > this.indexHeader.getEndTimestamp();
boolean result = begin < this.indexHeader.getBeginTimestamp() && end > this.indexHeader.getEndTimestamp();
result = result || (begin >= this.indexHeader.getBeginTimestamp() && begin <= this.indexHeader.getEndTimestamp());
result = result || (end >= this.indexHeader.getBeginTimestamp() && end <= this.indexHeader.getEndTimestamp());
return result;
......
......@@ -26,10 +26,6 @@ import org.apache.rocketmq.remoting.RPCHook;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class QueryMsgByKeySubCommand implements SubCommand {
@Override
......
......@@ -23,10 +23,6 @@ import org.apache.rocketmq.remoting.RPCHook;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class DeleteKvConfigCommand implements SubCommand {
@Override
public String commandName() {
......
......@@ -23,10 +23,6 @@ import org.apache.rocketmq.remoting.RPCHook;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class UpdateKvConfigCommand implements SubCommand {
@Override
public String commandName() {
......
......@@ -31,10 +31,6 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class ResetOffsetByTimeOldCommand implements SubCommand {
public static void resetOffset(DefaultMQAdminExt defaultMQAdminExt, String consumerGroup, String topic, long timestamp, boolean force,
String timeStampStr) throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
......
......@@ -31,10 +31,6 @@ import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.CommandUtil;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class DeleteTopicSubCommand implements SubCommand {
public static void deleteTopic(final DefaultMQAdminExt adminExt,
final String clusterName,
......
......@@ -24,10 +24,6 @@ import org.apache.rocketmq.remoting.RPCHook;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class TopicClusterSubCommand implements SubCommand {
@Override
......
......@@ -35,10 +35,6 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class TopicListSubCommand implements SubCommand {
@Override
......
......@@ -24,10 +24,6 @@ import org.apache.rocketmq.remoting.RPCHook;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class TopicRouteSubCommand implements SubCommand {
@Override
......
......@@ -30,10 +30,6 @@ import org.apache.rocketmq.remoting.RPCHook;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class TopicStatusSubCommand implements SubCommand {
@Override
......
......@@ -26,10 +26,6 @@ import org.apache.rocketmq.srvutil.ServerUtil;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
/**
*
*
*/
public class UpdateOrderConfCommand implements SubCommand {
@Override
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册