fix(java-client): fix client query meta server failed when authentica…

…tion is enabled
apache · Sep 9, 2024 · ab36f95 · ab36f95
1 parent d0e9260
commit ab36f95
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java b/java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java
@@ -249,6 +249,7 @@ void onFinishQueryMeta(final MetaRequestRound round) {
       return;
     }
 
+    round.lastSession.getInterceptorManager().onConnected(round.lastSession);
     retryQueryMeta(round, needDelay);
   }
 

diff --git a/java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java b/java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java
@@ -427,6 +427,10 @@ public boolean tryPendRequest(RequestEntry entry) {
     return false;
   }
 
+  public ReplicaSessionInterceptorManager getInterceptorManager() {
+    return interceptorManager;
+  }
+
   final class DefaultHandler extends SimpleChannelInboundHandler<RequestEntry> {
     @Override
     public void channelInactive(ChannelHandlerContext ctx) throws Exception {
-Original file line number
+Diff line change
@@ Expand Up / @@ -249,6 +249,7 @@ void onFinishQueryMeta(final MetaRequestRound round) { @@
           return;
         }
+        round.lastSession.getInterceptorManager().onConnected(round.lastSession);
         retryQueryMeta(round, needDelay);
       }
@@ Expand Down @@