From b94dcd0a60433d8c57677fec348e1ac292fe5c5e Mon Sep 17 00:00:00 2001 From: "Jixiang.jjx" Date: Wed, 27 Apr 2022 09:56:19 +0800 Subject: [PATCH] [ISSUE #3949] fix to fit checkStyle. --- proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java | 2 +- .../apache/rocketmq/proxy/grpc/v2/GrpcMessagingProcessor.java | 1 - .../rocketmq/proxy/grpc/v2/service/ClusterGrpcService.java | 1 - 3 files changed, 1 insertion(+), 3 deletions(-) diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java b/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java index 516a99506a..55f7526e58 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java @@ -81,7 +81,7 @@ public class ProxyStartup { System.exit(1); } - System.out.println(new Date() + " rmq-proxy startup successfully"); + System.out.printf("%s%n", new Date() + " rmq-proxy startup successfully"); log.info(new Date() + " rmq-proxy startup successfully"); } diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingProcessor.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingProcessor.java index 586061b3e4..ad06e23074 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingProcessor.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingProcessor.java @@ -44,7 +44,6 @@ import apache.rocketmq.v2.Status; import apache.rocketmq.v2.TelemetryCommand; import io.grpc.Context; import io.grpc.stub.StreamObserver; -import java.util.Iterator; import java.util.concurrent.CompletableFuture; import org.apache.rocketmq.proxy.grpc.v2.adapter.ResponseBuilder; import org.apache.rocketmq.proxy.grpc.v2.adapter.ResponseWriter; diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/ClusterGrpcService.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/ClusterGrpcService.java index bea689d077..40258fbb83 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/ClusterGrpcService.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/ClusterGrpcService.java @@ -56,7 +56,6 @@ import org.apache.rocketmq.proxy.common.TelemetryCommandManager; import org.apache.rocketmq.proxy.connector.ConnectorManager; import org.apache.rocketmq.proxy.connector.transaction.TransactionStateCheckRequest; import org.apache.rocketmq.proxy.connector.transaction.TransactionStateChecker; -import org.apache.rocketmq.proxy.grpc.v2.adapter.ProxyMode; import org.apache.rocketmq.proxy.grpc.v2.service.cluster.ConsumerService; import org.apache.rocketmq.proxy.grpc.v2.service.cluster.ForwardClientService; import org.apache.rocketmq.proxy.grpc.v2.service.cluster.ProducerService;