From 4d9a99dfd4547f50f21652b8751846ce0996b62b Mon Sep 17 00:00:00 2001 From: Abyss <45425302+wangxye@users.noreply.github.com> Date: Fri, 3 Nov 2023 03:14:36 -0500 Subject: [PATCH] fix: fix the grpc client api (#11) Signed-off-by: wangxye --- .../src/main/java/org/apache/rocketmq/factory/BaseFactory.java | 2 +- .../src/main/java/org/apache/rocketmq/frame/BaseOperate.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java b/java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java index a800b0f..5e08d39 100644 --- a/java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java +++ b/java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java @@ -17,7 +17,7 @@ package org.apache.rocketmq.factory; -import com.automq.rocketmq.controller.metadata.GrpcControllerClient; +import com.automq.rocketmq.controller.client.GrpcControllerClient; import com.automq.rocketmq.cli.CliClientConfig; import org.apache.rocketmq.client.apis.ClientServiceProvider; diff --git a/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java b/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java index a91927e..197b444 100644 --- a/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java +++ b/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java @@ -24,7 +24,7 @@ import apache.rocketmq.controller.v1.MessageType; import apache.rocketmq.controller.v1.AcceptTypes; import apache.rocketmq.controller.v1.SubscriptionMode; -import com.automq.rocketmq.controller.metadata.GrpcControllerClient; +import com.automq.rocketmq.controller.client.GrpcControllerClient; import com.automq.rocketmq.cli.CliClientConfig; import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletionException;