diff --git a/java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptorManager.java b/java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptorManager.java index e49e8c1465..639188c6e2 100644 --- a/java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptorManager.java +++ b/java-client/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 index f5bbf127b7..b498f9c2b7 100644 --- 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 index 3c1be3788f..bdabf82c7c 100644 --- 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(); } }