@InterfaceAudience.Private public class RetryInvocationHandler<T> extends Object implements RpcInvocationHandler
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
Modifier | Constructor and Description |
---|---|
protected |
RetryInvocationHandler(FailoverProxyProvider<T> proxyProvider,
RetryPolicy retryPolicy) |
protected |
RetryInvocationHandler(FailoverProxyProvider<T> proxyProvider,
RetryPolicy defaultPolicy,
Map<String,RetryPolicy> methodNameToPolicyMap) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Client.ConnectionId |
getConnectionId()
Returns the connection id associated with the InvocationHandler instance.
|
Object |
invoke(Object proxy,
Method method,
Object[] args) |
protected Object |
invokeMethod(Method method,
Object[] args) |
protected RetryInvocationHandler(FailoverProxyProvider<T> proxyProvider, RetryPolicy retryPolicy)
protected RetryInvocationHandler(FailoverProxyProvider<T> proxyProvider, RetryPolicy defaultPolicy, Map<String,RetryPolicy> methodNameToPolicyMap)
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable
invoke
in interface InvocationHandler
Throwable
protected Object invokeMethod(Method method, Object[] args) throws Throwable
Throwable
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public Client.ConnectionId getConnectionId()
RpcInvocationHandler
getConnectionId
in interface RpcInvocationHandler
Copyright © 2013 Apache Software Foundation. All rights reserved.