ROCKETMQ-18 Remove empty class doc.
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/2eae25c6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/2eae25c6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/2eae25c6 Branch: refs/heads/master Commit: 2eae25c6aaa7aaa4ed0ec38ecb656744f51ca5a1 Parents: 853b167 Author: yukon <[email protected]> Authored: Wed Dec 28 17:09:13 2016 +0800 Committer: yukon <[email protected]> Committed: Wed Dec 28 17:09:13 2016 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/rocketmq/common/admin/ConsumeStats.java | 4 ---- .../java/org/apache/rocketmq/common/admin/OffsetWrapper.java | 4 ---- .../main/java/org/apache/rocketmq/common/admin/TopicOffset.java | 4 ---- .../java/org/apache/rocketmq/common/admin/TopicStatsTable.java | 4 ---- .../java/org/apache/rocketmq/common/hook/FilterCheckHook.java | 4 ---- .../main/java/org/apache/rocketmq/common/message/Message.java | 4 ---- .../protocol/header/GetConsumerConnectionListRequestHeader.java | 4 ---- .../common/protocol/header/QueryCorrectionOffsetHeader.java | 4 ---- .../common/protocol/header/ResetOffsetRequestHeader.java | 4 ---- .../src/main/java/org/apache/rocketmq/store/index/IndexFile.java | 4 +--- .../rocketmq/tools/command/message/QueryMsgByKeySubCommand.java | 4 ---- .../rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java | 4 ---- .../rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java | 4 ---- .../tools/command/offset/ResetOffsetByTimeOldCommand.java | 4 ---- .../rocketmq/tools/command/topic/DeleteTopicSubCommand.java | 4 ---- .../rocketmq/tools/command/topic/TopicClusterSubCommand.java | 4 ---- .../apache/rocketmq/tools/command/topic/TopicListSubCommand.java | 4 ---- .../rocketmq/tools/command/topic/TopicRouteSubCommand.java | 4 ---- .../rocketmq/tools/command/topic/TopicStatusSubCommand.java | 4 ---- .../rocketmq/tools/command/topic/UpdateOrderConfCommand.java | 4 ---- 20 files changed, 1 insertion(+), 79 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java b/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java index 1fc8897..f3fd11c 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java +++ b/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java @@ -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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java b/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java index a5697ec..f255d30 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java +++ b/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java @@ -16,10 +16,6 @@ */ package org.apache.rocketmq.common.admin; -/** - * - * - */ public class OffsetWrapper { private long brokerOffset; private long consumerOffset; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java b/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java index 8147d63..d0af7d5 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java +++ b/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java @@ -16,10 +16,6 @@ */ package org.apache.rocketmq.common.admin; -/** - * - * - */ public class TopicOffset { private long minOffset; private long maxOffset; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java b/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java index 01f4557..d9ca9e4 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java +++ b/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java @@ -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>(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java b/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java index a0a7925..5f70120 100644 --- a/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java +++ b/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java @@ -19,10 +19,6 @@ package org.apache.rocketmq.common.hook; import java.nio.ByteBuffer; -/** - * - * - */ public interface FilterCheckHook { public String hookName(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/message/Message.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/message/Message.java b/common/src/main/java/org/apache/rocketmq/common/message/Message.java index 00cb6d1..a35774f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/Message.java +++ b/common/src/main/java/org/apache/rocketmq/common/message/Message.java @@ -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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java index 8f12c79..6c6f368 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java @@ -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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java index db5b306..4342035 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java @@ -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 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/common/src/main/java/org/apache/rocketmq/common/protocol/header/ResetOffsetRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/ResetOffsetRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/ResetOffsetRequestHeader.java index 920760b..a8881e3 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/ResetOffsetRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/ResetOffsetRequestHeader.java @@ -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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java ---------------------------------------------------------------------- diff --git a/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java b/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java index 97f3920..9cec902 100644 --- a/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java +++ b/store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java @@ -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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java index 159bd6e..a779466 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java @@ -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 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java index b4fb7dd..3487c50 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java @@ -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() { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java index 9d5f7a9..5c58aa3 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java @@ -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() { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java index 9b30474..f7428d3 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java @@ -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 { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java index 69cbc99..95f276e 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java @@ -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, http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java index 6a267a5..3e2eb20 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java @@ -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 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java index 5e23a96..2359fe1 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java @@ -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 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java index b7a180f..ca356cc 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java @@ -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 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java index 76d9cbc..460feb3 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java @@ -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 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2eae25c6/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java ---------------------------------------------------------------------- diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java index f9f4f1f..896c125 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java @@ -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
