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

[ISSUE #3949] Fix v2 endpoint for protocol

Browse Source
This commit is contained in:
zhouxiang
2022-07-13 11:29:17 +08:00
parent bc7fbfd46f
commit f255f1bc3a
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/service/cluster/RouteService.java
+4 -2
View File
@@ -114,11 +114,13 @@ public class RouteService extends BaseService {
List<MessageQueue> 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;
}