[accumulo] branch master updated: Remove duplicate close in ReplicationClient

[mmiller]

This is an automated email from the ASF dual-hosted git repository.

mmiller pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/master by this push:
     new 6539df6  Remove duplicate close in ReplicationClient
6539df6 is described below

commit 6539df69aa741a280e9297e8f398929e37823953
Author: Mike Miller <mmil...@apache.org>
AuthorDate: Wed Jan 2 15:56:22 2019 -0500

    Remove duplicate close in ReplicationClient
---
 .../apache/accumulo/core/clientImpl/ReplicationClient.java  | 13 +------------
 1 file changed, 1 insertion(+), 12 deletions(-)

diff --git 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/ReplicationClient.java 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/ReplicationClient.java
index f8310dd..9b404ed 100644
--- 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/ReplicationClient.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/ReplicationClient.java
@@ -138,18 +138,7 @@ public class ReplicationClient {
     }
   }
 
-  public static void close(ReplicationCoordinator.Iface iface) {
-    TServiceClient client = (TServiceClient) iface;
-    if (client != null && client.getInputProtocol() != null
-        && client.getInputProtocol().getTransport() != null) {
-      
ThriftTransportPool.getInstance().returnTransport(client.getInputProtocol().getTransport());
-    } else {
-      log.debug("Attempt to close null connection to the remote system", new 
Exception());
-    }
-  }
-
-  public static void close(ReplicationServicer.Iface iface) {
-    TServiceClient client = (TServiceClient) iface;
+  private static void close(TServiceClient client) {
     if (client != null && client.getInputProtocol() != null
         && client.getInputProtocol().getTransport() != null) {
       
ThriftTransportPool.getInstance().returnTransport(client.getInputProtocol().getTransport());