类com.alibaba.dubbo.rpc.proxy.AbstractProxyInvoker源码实例Demo

下面列出了怎么用com.alibaba.dubbo.rpc.proxy.AbstractProxyInvoker的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: pinpoint   文件: DubboProviderIT.java
@Test
public void testProvider() {
    AbstractProxyInvoker abstractProxyInvoker = new AbstractProxyInvoker(new String(), String.class, url) {
        @Override
        protected Object doInvoke(Object proxy, String methodName, Class[] parameterTypes, Object[] arguments) throws Throwable {
            Method method = proxy.getClass().getMethod(methodName, parameterTypes);
            return method.invoke(proxy, arguments);
        }
    };
    try {
        abstractProxyInvoker.invoke(rpcInvocation);
    } catch (RpcException ignore) {
        ignore.printStackTrace();
    }

    PluginTestVerifier verifier = PluginTestVerifierHolder.getInstance();
    verifier.printCache();

    verifier.verifyTraceCount(2);
}
 
源代码2 项目: pinpoint   文件: DubboProviderIT.java
@Test
public void testDoNotTrace() {
    when(rpcInvocation.getAttachment(META_DO_NOT_TRACE)).thenReturn("1");

    AbstractProxyInvoker abstractProxyInvoker = new AbstractProxyInvoker(new String(), String.class, url) {
        @Override
        protected Object doInvoke(Object proxy, String methodName, Class[] parameterTypes, Object[] arguments) throws Throwable {
            Method method = proxy.getClass().getMethod(methodName, parameterTypes);
            return method.invoke(proxy, arguments);
        }
    };
    try {
        abstractProxyInvoker.invoke(rpcInvocation);
    } catch (RpcException ignore) {
        ignore.printStackTrace();
    }

    PluginTestVerifier verifier = PluginTestVerifierHolder.getInstance();
    verifier.printCache();
    verifier.verifyTraceCount(0);
}
 
 类所在包
 类方法
 同包方法