Index: security/src/main/java/org/apache/hadoop/hbase/ipc/SecureRpcEngine.java =================================================================== --- security/src/main/java/org/apache/hadoop/hbase/ipc/SecureRpcEngine.java (revision 1394901) +++ security/src/main/java/org/apache/hadoop/hbase/ipc/SecureRpcEngine.java (working copy) @@ -196,7 +196,7 @@ public VersionedProtocol getProxy( Class protocol, long clientVersion, InetSocketAddress addr, User ticket, - Configuration conf, SocketFactory factory, int rpcTimeout) + Configuration conf, SocketFactory factory, int rpcTimeout, InvocationHandler handler) throws IOException { if (User.isSecurityEnabled()) { HBaseSaslRpcServer.init(conf); @@ -204,7 +204,7 @@ VersionedProtocol proxy = (VersionedProtocol) Proxy.newProxyInstance( protocol.getClassLoader(), new Class[] { protocol }, - new Invoker(protocol, addr, ticket, conf, factory, rpcTimeout)); + handler); long serverVersion = proxy.getProtocolVersion(protocol.getName(), clientVersion); if (serverVersion != clientVersion) { @@ -214,6 +214,14 @@ return proxy; } + public VersionedProtocol getProxy(Class protocol, + long clientVersion, InetSocketAddress addr, + User ticket, Configuration conf, + SocketFactory factory, int rpcTimeout) throws IOException { + return getProxy(protocol, clientVersion, addr, ticket, conf, factory, rpcTimeout, + new Invoker(protocol, addr, ticket, conf, factory, rpcTimeout)); + } + /** * Stop this proxy and release its invoker's resource * @param proxy the proxy to be stopped