From f255f1bc3a38419b8fc751f9c470860c804c8e57 Mon Sep 17 00:00:00 2001 From: zhouxiang Date: Mon, 11 Apr 2022 15:49:48 +0800 Subject: [PATCH] [ISSUE #3949] Fix v2 endpoint for protocol --- .../proxy/grpc/v2/service/cluster/RouteService.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/cluster/RouteService.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/cluster/RouteService.java index d107b093a4..2b240eca41 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/cluster/RouteService.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/cluster/RouteService.java @@ -114,11 +114,13 @@ public class RouteService extends BaseService { List messageQueueList = new ArrayList<>(); if (ProxyMode.isClusterMode(mode.name())) { - Endpoints resEndpoints = this.queryRouteEndpointConverter.convert(ctx, request.getEndpoints()); + String clientId = InterceptorConstants.METADATA.get(ctx).get(InterceptorConstants.CLIENT_ID); + ClientSettings clientSettings = grpcClientManager.getClientSettings(clientId); + Endpoints resEndpoints = this.queryRouteEndpointConverter.convert(ctx, clientSettings.getAccessPoint()); if (resEndpoints == null || resEndpoints.getDefaultInstanceForType().equals(resEndpoints)) { future.complete(QueryRouteResponse.newBuilder() .setStatus(ResponseBuilder.buildStatus(Code.ILLEGAL_ACCESS_POINT, "endpoint " + - request.getEndpoints() + " is invalidate")) + clientSettings.getAccessPoint() + " is invalidate")) .build()); return future; }