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; }