Merge pull request #3444 from VirajSalaka/choreo

Bug fix: KeyManager discovery client's max inbound message size cannot be increased
wso2 · Oct 10, 2023 · c382cd0 · c382cd0
2 parents be2d127 + f7bab4c
commit c382cd0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...r/src/main/java/org/wso2/choreo/connect/enforcer/discovery/KeyManagerDiscoveryClient.java b/...r/src/main/java/org/wso2/choreo/connect/enforcer/discovery/KeyManagerDiscoveryClient.java
@@ -122,7 +122,8 @@ public void run() {
 
     public void watchKeyManagers() {
         // TODO: implement a deadline with retries
-        reqObserver = stub.streamKeyManagers(new StreamObserver<>() {
+        int maxSize = Integer.parseInt(ConfigHolder.getInstance().getEnvVarConfig().getXdsMaxMsgSize());
+        reqObserver = stub.withMaxInboundMessageSize(maxSize).streamKeyManagers(new StreamObserver<>() {
             @Override
             public void onNext(DiscoveryResponse response) {
                 logger.info("Key manager event received with version : " + response.getVersionInfo());