From 2eae25c6aaa7aaa4ed0ec38ecb656744f51ca5a1 Mon Sep 17 00:00:00 2001 From: yukon Date: Wed, 28 Dec 2016 17:09:13 +0800 Subject: [PATCH] ROCKETMQ-18 Remove empty class doc. --- .../java/org/apache/rocketmq/common/admin/ConsumeStats.java | 4 ---- .../java/org/apache/rocketmq/common/admin/OffsetWrapper.java | 4 ---- .../java/org/apache/rocketmq/common/admin/TopicOffset.java | 4 ---- .../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 ---- .../header/GetConsumerConnectionListRequestHeader.java | 4 ---- .../common/protocol/header/QueryCorrectionOffsetHeader.java | 4 ---- .../common/protocol/header/ResetOffsetRequestHeader.java | 4 ---- .../main/java/org/apache/rocketmq/store/index/IndexFile.java | 4 +--- .../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 ---- .../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(-) 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 1fc8897c..f3fd11c6 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 offsetTable = new HashMap(); private double consumeTps = 0; 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 a5697ecb..f255d305 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; 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 8147d634..d0af7d56 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; 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 01f4557d..d9ca9e41 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 offsetTable = new HashMap(); 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 a0a79257..5f701205 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(); 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 00cb6d16..a35774f8 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; 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 8f12c79a..6c6f3688 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; 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 db5b3065..4342035c 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 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 920760bf..a8881e31 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; 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 97f39200..9cec902f 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; 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 159bd6ea..a7794660 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 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 b4fb7ddc..3487c505 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() { 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 9d5f7a9c..5c58aa30 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() { 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 9b304742..f7428d35 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 { 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 69cbc99c..95f276e0 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, 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 6a267a55..3e2eb207 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 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 5e23a96d..2359fe1e 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 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 b7a180fd..ca356cc7 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 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 76d9cbca..460feb3c 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 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 f9f4f1f7..896c125f 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 -- GitLab