opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 13:49:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix check style

Browse Source
This commit is contained in:
dongeforever
2022-02-08 10:38:41 +08:00
committed by RongtongJin
parent a767cc1424
commit 372e42ff45
3 changed files with 4 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
-2
View File
@@ -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;
common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java
+3 -5
View File
@@ -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;
common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java
+1 -4
View File
@@ -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 {