This is an automated email from the ASF dual-hosted git repository. dongeforever pushed a commit to branch 5.0.0-alpha in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 16128dbbd88bbd797671ae02a52a73eec24838a3 Author: dongeforever <[email protected]> AuthorDate: Wed Jan 5 17:29:26 2022 +0800 Fix check style --- .../rocketmq/common/protocol/header/CreateTopicRequestHeader.java | 2 -- .../main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java | 8 +++----- .../apache/rocketmq/common/statictopic/TopicQueueMappingOne.java | 5 +---- 3 files changed, 4 insertions(+), 11 deletions(-) diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java index 2e381b3..c3c59d4 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java @@ -26,8 +26,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull; import org.apache.rocketmq.remoting.annotation.CFNullable; import org.apache.rocketmq.remoting.exception.RemotingCommandException; -import java.util.Map; - public class CreateTopicRequestHeader implements CommandCustomHeader { @CFNotNull private String topic; diff --git a/common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java b/common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java index 3782ab0..c5cbc74 100644 --- a/common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java +++ b/common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java @@ -18,6 +18,9 @@ package org.apache.rocketmq.common.rpc; import io.netty.util.concurrent.ImmediateEventExecutor; import io.netty.util.concurrent.Promise; +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.Future; import org.apache.rocketmq.common.admin.TopicStatsTable; import org.apache.rocketmq.common.message.MessageQueue; import org.apache.rocketmq.common.protocol.RequestCode; @@ -28,7 +31,6 @@ import org.apache.rocketmq.common.protocol.header.GetMinOffsetResponseHeader; import org.apache.rocketmq.common.protocol.header.PullMessageResponseHeader; import org.apache.rocketmq.common.protocol.header.QueryConsumerOffsetResponseHeader; import org.apache.rocketmq.common.protocol.header.SearchOffsetResponseHeader; -import org.apache.rocketmq.common.protocol.header.UpdateConsumerOffsetRequestHeader; import org.apache.rocketmq.common.protocol.header.UpdateConsumerOffsetResponseHeader; import org.apache.rocketmq.common.statictopic.TopicConfigAndQueueMapping; import org.apache.rocketmq.remoting.InvokeCallback; @@ -37,10 +39,6 @@ import org.apache.rocketmq.remoting.netty.ResponseFuture; import org.apache.rocketmq.remoting.protocol.RemotingCommand; import org.apache.rocketmq.remoting.protocol.RemotingSerializable; -import java.util.ArrayList; -import java.util.List; -import java.util.concurrent.Future; - public class RpcClientImpl implements RpcClient { private ClientMetadata clientMetadata; diff --git a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java index 636f1d5..597b6ab 100644 --- a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java +++ b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java @@ -16,11 +16,8 @@ */ package org.apache.rocketmq.common.statictopic; -import org.apache.commons.lang3.builder.EqualsBuilder; -import org.apache.commons.lang3.builder.HashCodeBuilder; -import org.apache.rocketmq.remoting.protocol.RemotingSerializable; - import java.util.List; +import org.apache.rocketmq.remoting.protocol.RemotingSerializable; public class TopicQueueMappingOne extends RemotingSerializable {
