From 372e42ff454836c7787c33316934c641e1359ebf Mon Sep 17 00:00:00 2001 From: dongeforever Date: Wed, 5 Jan 2022 17:29:26 +0800 Subject: [PATCH] Fix check style --- .../common/protocol/header/CreateTopicRequestHeader.java | 2 -- .../org/apache/rocketmq/common/rpc/RpcClientImpl.java | 8 +++----- .../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 2e381b3404..c3c59d4950 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 3782ab0f8d..c5cbc740b4 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 636f1d5098..597b6abe94 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 {