com.alibaba.dubbo.rpc.support.Type源码实例Demo-星河码客

类com.alibaba.dubbo.rpc.support.Type源码实例Demo

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

源代码1 项目： dubbo-2.6.5 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerJsonPojoSerialization() {
    invocation = mock(Invocation.class);
    given(invocation.getMethodName()).willReturn("enumlength");
    given(invocation.getParameterTypes()).willReturn(new Class<?>[]{Type[].class});
    given(invocation.getArguments()).willReturn(new Object[]{"hello"});

    invoker = mock(Invoker.class);
    given(invoker.isAvailable()).willReturn(true);
    given(invoker.getInterface()).willReturn(DemoService.class);
    RpcResult result = new RpcResult();
    result.setValue("High");
    given(invoker.invoke(invocation)).willReturn(result);
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1&serialization=json");
    given(invoker.getUrl()).willReturn(url);

    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码2 项目： dubbo-2.6.5 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerNonJsonEnumSerialization() {
    invocation = mock(Invocation.class);
    given(invocation.getMethodName()).willReturn("enumlength");
    given(invocation.getParameterTypes()).willReturn(new Class<?>[]{Type[].class});
    given(invocation.getArguments()).willReturn(new Object[]{"hello"});

    invoker = mock(Invoker.class);
    given(invoker.isAvailable()).willReturn(true);
    given(invoker.getInterface()).willReturn(DemoService.class);
    RpcResult result = new RpcResult();
    result.setValue("High");
    given(invoker.invoke(invocation)).willReturn(result);
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1");
    given(invoker.getUrl()).willReturn(url);

    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码3 项目： dubbox 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerJsonPojoSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1&serialization=json");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码4 项目： dubbox 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerNonJsonEnumSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码5 项目： dubbox-hystrix 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerJsonPojoSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1&serialization=json");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码6 项目： dubbox-hystrix 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerNonJsonEnumSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码7 项目： dubbo3 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerJsonPojoSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1&serialization=json");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码8 项目： dubbo3 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerNonJsonEnumSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码9 项目： dubbox 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerJsonPojoSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1&serialization=json");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码10 项目： dubbox 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerNonJsonEnumSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码11 项目： dubbox 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerJsonPojoSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1&serialization=json");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码12 项目： dubbox 文件： CompatibleFilterFilterTest.java

@Test
public void testInvokerNonJsonEnumSerialization() {
    invocation = EasyMock.createMock(Invocation.class);
    EasyMock.expect(invocation.getMethodName()).andReturn("enumlength").anyTimes();
    EasyMock.expect(invocation.getParameterTypes()).andReturn(new Class<?>[] { Type[].class }).anyTimes();
    EasyMock.expect(invocation.getArguments()).andReturn(new Object[] { "hello" }).anyTimes();
    EasyMock.replay(invocation);
    invoker = EasyMock.createMock(Invoker.class);
    EasyMock.expect(invoker.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker.getInterface()).andReturn(DemoService.class).anyTimes();
    RpcResult result = new RpcResult();
    result.setValue("High");
    EasyMock.expect(invoker.invoke(invocation)).andReturn(result).anyTimes();
    URL url = URL.valueOf("test://test:11/test?group=dubbo&version=1.1");
    EasyMock.expect(invoker.getUrl()).andReturn(url).anyTimes();
    EasyMock.replay(invoker);
    Result filterResult = compatibleFilter.invoke(invoker, invocation);
    assertEquals(Type.High, filterResult.getValue());
}

源代码13 项目： dubbo-2.6.5 文件： CustomArgument.java

public CustomArgument(Type type, String name) {
    super();
    this.type = type;
    this.name = name;
}

源代码14 项目： dubbo-2.6.5 文件： CustomArgument.java

public Type getType() {
    return type;
}

源代码15 项目： dubbo-2.6.5 文件： CustomArgument.java

public void setType(Type type) {
    this.type = type;
}

源代码16 项目： dubbox 文件： CustomArgument.java

public CustomArgument(Type type, String name) {
    super();
    this.type = type;
    this.name = name;
}

源代码17 项目： dubbox 文件： CustomArgument.java

public Type getType() {
    return type;
}

源代码18 项目： dubbox 文件： CustomArgument.java

public void setType(Type type) {
    this.type = type;
}

源代码19 项目： dubbox-hystrix 文件： CustomArgument.java

public CustomArgument(Type type, String name) {
    super();
    this.type = type;
    this.name = name;
}

源代码20 项目： dubbox-hystrix 文件： CustomArgument.java

public Type getType() {
    return type;
}

源代码21 项目： dubbox-hystrix 文件： CustomArgument.java

public void setType(Type type) {
    this.type = type;
}

源代码22 项目： dubbo3 文件： CustomArgument.java

public CustomArgument(Type type, String name) {
    super();
    this.type = type;
    this.name = name;
}

源代码23 项目： dubbo3 文件： CustomArgument.java

public Type getType() {
    return type;
}

源代码24 项目： dubbo3 文件： CustomArgument.java

public void setType(Type type) {
    this.type = type;
}

源代码25 项目： dubbox 文件： CustomArgument.java

public CustomArgument(Type type, String name) {
    super();
    this.type = type;
    this.name = name;
}

源代码26 项目： dubbox 文件： CustomArgument.java

public Type getType() {
    return type;
}

源代码27 项目： dubbox 文件： CustomArgument.java

public void setType(Type type) {
    this.type = type;
}

源代码28 项目： dubbox 文件： CustomArgument.java

public CustomArgument(Type type, String name) {
    super();
    this.type = type;
    this.name = name;
}

源代码29 项目： dubbox 文件： CustomArgument.java

public Type getType() {
    return type;
}

源代码30 项目： dubbox 文件： CustomArgument.java

public void setType(Type type) {
    this.type = type;
}

类所在包

com.alibaba.dubbo.rpc

类方法

同包方法

com.alibaba.dubbo.rpc.RpcContext

com.alibaba.dubbo.rpc.Invocation

com.alibaba.dubbo.rpc.Invoker

com.alibaba.dubbo.rpc.RpcException

com.alibaba.dubbo.rpc.Result

com.alibaba.dubbo.rpc.Filter

com.alibaba.dubbo.rpc.service.GenericService

com.alibaba.dubbo.rpc.RpcResult

com.alibaba.dubbo.rpc.RpcInvocation

com.alibaba.dubbo.rpc.support.RpcUtils

com.alibaba.dubbo.rpc.protocol.dubbo.FutureAdapter

com.alibaba.dubbo.rpc.cluster.LoadBalance

com.alibaba.dubbo.rpc.Exporter

com.alibaba.dubbo.rpc.service.GenericException

com.alibaba.dubbo.rpc.Protocol

com.alibaba.dubbo.rpc.cluster.loadbalance.RandomLoadBalance

com.alibaba.dubbo.rpc.ProxyFactory

com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol

com.alibaba.dubbo.rpc.cluster.loadbalance.RoundRobinLoadBalance

com.alibaba.dubbo.rpc.service.EchoService

com.alibaba.dubbo.rpc.cluster.directory.StaticDirectory

com.alibaba.dubbo.rpc.proxy.AbstractProxyInvoker

com.alibaba.dubbo.rpc.protocol.dubbo.filter.FutureFilter

com.alibaba.dubbo.rpc.protocol.AbstractInvoker

com.alibaba.dubbo.rpc.protocol.AbstractProxyProtocol

com.alibaba.dubbo.rpc.cluster.loadbalance.LeastActiveLoadBalance

com.alibaba.dubbo.rpc.proxy.InvokerInvocationHandler

com.alibaba.dubbo.rpc.cluster.Directory

com.alibaba.dubbo.rpc.cluster.support.AvailableCluster

com.alibaba.dubbo.rpc.cluster.Cluster

com.alibaba.dubbo.rpc.cluster.router.MockInvoker

com.alibaba.dubbo.rpc.listener.ListenerExporterWrapper

com.alibaba.dubbo.rpc.protocol.AbstractProtocol

com.alibaba.dubbo.rpc.support.MyInvoker

com.alibaba.dubbo.rpc.support.MockProtocol

com.alibaba.dubbo.rpc.ExporterListener

com.alibaba.dubbo.rpc.support.MockInvoker

com.alibaba.dubbo.rpc.cluster.configurator.AbstractConfigurator

com.alibaba.dubbo.rpc.support.ProtocolUtils

com.alibaba.dubbo.rpc.protocol.dubbo.support.RemoteService

com.alibaba.dubbo.rpc.cluster.support.FailoverCluster

com.alibaba.dubbo.rpc.cluster.Router

com.alibaba.dubbo.rpc.cluster.directory.AbstractDirectory

com.alibaba.dubbo.rpc.cluster.RouterFactory

com.alibaba.dubbo.rpc.cluster.Configurator

com.alibaba.dubbo.rpc.filter.tps.TPSLimiter

com.alibaba.dubbo.rpc.protocol.dubbo.support.DemoService

com.alibaba.dubbo.rpc.support.Type

com.alibaba.dubbo.rpc.protocol.dubbo.support.RemoteServiceImpl

com.alibaba.dubbo.rpc.protocol.dubbo.filter.TraceFilter

com.alibaba.dubbo.rpc.cluster.router.script.ScriptRouterFactory

com.alibaba.dubbo.rpc.protocol.injvm.InjvmProtocol

com.alibaba.dubbo.rpc.support.MockInvocation

com.alibaba.dubbo.rpc.protocol.dubbo.support.ProtocolUtils

com.alibaba.dubbo.rpc.protocol.dubbo.DubboInvoker

com.alibaba.dubbo.rpc.RpcStatus

com.alibaba.dubbo.rpc.cluster.router.MockInvokersSelector

com.alibaba.dubbo.rpc.protocol.dubbo.support.Type

com.alibaba.dubbo.rpc.InvokerListener

com.alibaba.dubbo.rpc.cluster.ConfiguratorFactory

com.alibaba.dubbo.rpc.protocol.InvokerWrapper

com.alibaba.dubbo.rpc.cluster.merger.MergerFactory

com.alibaba.dubbo.rpc.protocol.AbstractExporter

com.alibaba.dubbo.rpc.protocol.dubbo.support.NonSerialized

com.alibaba.dubbo.rpc.cluster.filter.DemoService

com.alibaba.dubbo.rpc.protocol.rest.support.ContentType

com.alibaba.dubbo.rpc.filter.tps.DefaultTPSLimiter

com.alibaba.dubbo.rpc.cluster.support.AbstractClusterInvoker

com.alibaba.dubbo.rpc.cluster.support.ClusterUtils

com.alibaba.dubbo.rpc.cluster.Merger

com.alibaba.dubbo.rpc.protocol.dubbo.support.DemoServiceImpl

com.alibaba.dubbo.rpc.CustomArgument

com.alibaba.dubbo.rpc.support.DemoService

com.alibaba.dubbo.rpc.proxy.AbstractProxyFactory

com.alibaba.dubbo.rpc.listener.ListenerInvokerWrapper

com.alibaba.dubbo.rpc.StaticContext

com.alibaba.dubbo.rpc.protocol.thrift.io.RandomAccessByteArrayOutputStream

com.alibaba.dubbo.rpc.protocol.dubbo.DubboExporter

com.alibaba.dubbo.rpc.cluster.support.FailfastCluster

com.alibaba.dubbo.rpc.protocol.thrift.ThriftUtils

com.alibaba.dubbo.rpc.protocol.thrift.ThriftCodec

com.alibaba.dubbo.rpc.ServiceClassHolder

com.alibaba.dubbo.rpc.gen.dubbo.Demo

com.alibaba.dubbo.rpc.protocol.thrift.ext.MultiServiceProcessor

com.alibaba.dubbo.rpc.gen.thrift.Demo

com.alibaba.dubbo.rpc.protocol.hessian.HessianServiceImpl.MyException

com.alibaba.dubbo.rpc.cluster.router.script.ScriptRouter

com.alibaba.dubbo.rpc.benchmark.AbstractClientRunnable

com.alibaba.dubbo.rpc.benchmark.DemoService

com.alibaba.dubbo.rpc.benchmark.ServiceFactory