fix(java-client): fix client thread leak when kerberos relogin failed

apache · Apr 12, 2024 · 8ee0ba1 · 8ee0ba1
1 parent 89d9712
commit 8ee0ba1
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...nt/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptorManager.java b/...nt/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptorManager.java
@@ -50,7 +50,7 @@ public boolean onSendMessage(ReplicaSession session, final ReplicaSession.Reques
     return true;
   }
 
-  public void close(){
+  public void close() {
     for (ReplicaSessionInterceptor interceptor : interceptors) {
       interceptor.close();
     }

diff --git a/java-client/src/main/java/org/apache/pegasus/security/AuthReplicaSessionInterceptor.java b/java-client/src/main/java/org/apache/pegasus/security/AuthReplicaSessionInterceptor.java
@@ -40,7 +40,7 @@ public boolean onSendMessage(ReplicaSession session, final ReplicaSession.Reques
     return protocol.isAuthRequest(entry) || !session.tryPendRequest(entry);
   }
 
-  public void close(){
+  public void close() {
     protocol.close();
   }
 }
diff --git a/java-client/src/main/java/org/apache/pegasus/security/KerberosProtocol.java b/java-client/src/main/java/org/apache/pegasus/security/KerberosProtocol.java
@@ -213,7 +213,7 @@ public AppConfigurationEntry[] getAppConfigurationEntry(String name) {
     };
   }
 
-  public void close(){
+  public void close() {
     service.shutdown();
   }
 }