| package org.apache.dubbo.migration; |
| |
| import org.apache.dubbo.common.constants.CommonConstants; |
| import org.apache.dubbo.config.ApplicationConfig; |
| import org.apache.dubbo.config.ReferenceConfig; |
| import org.apache.dubbo.config.RegistryConfig; |
| import org.apache.dubbo.config.bootstrap.DubboBootstrap; |
| |
| import org.junit.Assert; |
| import org.junit.Test; |
| |
| /** |
| * @author plusman |
| * @since 2021/9/12 11:52 AM |
| */ |
| public class ApiConsumerIT { |
| @Test |
| public void consumeInvoke() { |
| ReferenceConfig<GreeterService> referenceConfig = new ReferenceConfig<>(); |
| referenceConfig.setInterface(GreeterService.class); |
| referenceConfig.setCheck(false); |
| referenceConfig.setProtocol(CommonConstants.TRIPLE); |
| referenceConfig.setLazy(true); |
| referenceConfig.setTimeout(100000); |
| |
| DubboBootstrap bootstrap = DubboBootstrap.getInstance(); |
| bootstrap.application(new ApplicationConfig("dubbo-demo-triple-api-consumer")) |
| .registry(new RegistryConfig("zookeeper://" + System.getProperty("zookeeper.address", "127.0.0.1") + ":2181")) |
| .reference(referenceConfig) |
| .start(); |
| |
| GreeterService greeterService = referenceConfig.get(); |
| final HelloReply reply = greeterService.sayHello(HelloRequest.newBuilder() |
| .setName("triple") |
| .build()); |
| |
| Assert.assertEquals("Hello triple", reply.getMessage()); |
| } |
| } |