import org.springframework.remoting.RemoteProxyFailureException; //导入依赖的package包/类
@Override
public Object invoke(MethodInvocation methodInvocation) throws Throwable {

	Object thriftProxy = ThriftUtil.buildClient(getServiceInterface(), protocolFactory.getProtocol(getTransport()));

	ClassLoader originalClassLoader = overrideThreadContextClassLoader();
	try {
		return methodInvocation.getMethod().invoke(thriftProxy, methodInvocation.getArguments());
	} catch (InvocationTargetException e) {
		Throwable targetEx = e.getTargetException();
		if (targetEx instanceof InvocationTargetException) {
			targetEx = ((InvocationTargetException) targetEx).getTargetException();
		}
		if (targetEx instanceof TApplicationException && ((TApplicationException) targetEx).getType() == TApplicationException.MISSING_RESULT) {
			return null;
		} else {
			throw targetEx;
		}
	} catch (Throwable ex) {
		throw new RemoteProxyFailureException("Failed to invoke Thrift proxy for remote service [" + getServiceUrl() + "]", ex);
	} finally {
		resetThreadContextClassLoader(originalClassLoader);
	}
}
 

import org.springframework.remoting.RemoteProxyFailureException; //导入依赖的package包/类
@Test
public void rmiProxyFactoryBeanWithWrongBusinessInterface() throws Exception {
	CountingRmiProxyFactoryBean factory = new CountingRmiProxyFactoryBean();
	factory.setServiceInterface(IWrongBusinessBean.class);
	factory.setServiceUrl("rmi://localhost:1090/test");
	factory.afterPropertiesSet();
	assertTrue(factory.getObject() instanceof IWrongBusinessBean);
	IWrongBusinessBean proxy = (IWrongBusinessBean) factory.getObject();
	assertFalse(proxy instanceof IRemoteBean);
	try {
		proxy.setOtherName("name");
		fail("Should have thrown RemoteProxyFailureException");
	}
	catch (RemoteProxyFailureException ex) {
		assertTrue(ex.getCause() instanceof NoSuchMethodException);
		assertTrue(ex.getMessage().contains("setOtherName"));
		assertTrue(ex.getMessage().contains("IWrongBusinessBean"));
	}
	assertEquals(1, factory.counter);
}
 

import org.springframework.remoting.RemoteProxyFailureException; //导入依赖的package包/类
public void testRmiProxyFactoryBeanWithWrongBusinessInterface() throws Exception {
	CountingRmiProxyFactoryBean factory = new CountingRmiProxyFactoryBean();
	factory.setServiceInterface(IWrongBusinessBean.class);
	factory.setServiceUrl("rmi://localhost:1090/test");
	factory.afterPropertiesSet();
	assertTrue(factory.getObject() instanceof IWrongBusinessBean);
	IWrongBusinessBean proxy = (IWrongBusinessBean) factory.getObject();
	assertFalse(proxy instanceof IRemoteBean);
	try {
		proxy.setOtherName("name");
		fail("Should have thrown RemoteProxyFailureException");
	}
	catch (RemoteProxyFailureException ex) {
		assertTrue(ex.getCause() instanceof NoSuchMethodException);
		assertTrue(ex.getMessage().indexOf("setOtherName") != -1);
		assertTrue(ex.getMessage().indexOf("IWrongBusinessBean") != -1);
	}
	assertEquals(1, factory.counter);
}
 

import org.springframework.remoting.RemoteProxyFailureException; //导入依赖的package包/类
@Override
public Object invoke(MethodInvocation methodInvocation) throws Throwable {
    if (this.thriftProxy == null) {
        throw new IllegalStateException("ThriftClientInterceptor is not properly initialized - " +
                "invoke 'prepare' before attempting any operations");
    }

    ClassLoader originalClassLoader = overrideThreadContextClassLoader();
    try {
        return methodInvocation.getMethod().invoke(thriftProxy, methodInvocation.getArguments());
    } catch (InvocationTargetException e) {
        Throwable targetEx = e.getTargetException();
        if (targetEx instanceof InvocationTargetException) {
            targetEx = ((InvocationTargetException) targetEx).getTargetException();
        }
        if (targetEx instanceof TApplicationException && ((TApplicationException) targetEx).getType() == TApplicationException.MISSING_RESULT) {
            return null;
        } else {
            throw targetEx;
        }
    } catch (Throwable ex) {
        throw new RemoteProxyFailureException(
                "Failed to invoke Thrift proxy for remote service [" + getServiceUrl() + "]", ex);
    } finally {
        resetThreadContextClassLoader(originalClassLoader);
    }
}