Skip to content

Commit

Permalink
fix unit test (#1291)
Browse files Browse the repository at this point in the history
Co-authored-by: liujianjun.ljj <liujianjun.ljj@antgroup.com>
  • Loading branch information
EvenLjj and liujianjun.ljj authored Jan 2, 2023
1 parent 7931102 commit 1e386ed
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,13 +51,14 @@ public class TripleAsyncInvokeTest {
@BeforeClass
public static void start() {
ServerConfig serverConfig2 = new ServerConfig()
.setPort(22223)
.setPort(50053)
.setProtocol(RpcConstants.PROTOCOL_TYPE_TRIPLE)
.setDaemon(false);

// 服务端
ProviderConfig<HelloService> CProvider = new ProviderConfig<HelloService>()
.setInterfaceId(HelloService.class.getName())
.setBootstrap(RpcConstants.PROTOCOL_TYPE_TRIPLE)
.setRef(new HelloServiceImpl(1000))
.setServer(serverConfig2);
CProvider.export();
Expand All @@ -68,15 +69,15 @@ public static void start() {
.setInvokeType(RpcConstants.INVOKER_TYPE_FUTURE)
.setTimeout(5000)
.setProtocol(RpcConstants.PROTOCOL_TYPE_TRIPLE)
.setDirectUrl("127.0.0.1:22223");
.setDirectUrl("127.0.0.1:50053");
future = BConsumer.refer();

ConsumerConfig<HelloService> BBConsumer = new ConsumerConfig<HelloService>()
.setInterfaceId(HelloService.class.getName())
.setInvokeType(RpcConstants.INVOKER_TYPE_CALLBACK)
.setTimeout(5000)
.setProtocol(RpcConstants.PROTOCOL_TYPE_TRIPLE)
.setDirectUrl("127.0.0.1:22223");
.setDirectUrl("127.0.0.1:50053");
callback = BBConsumer.refer();
}

Expand Down

0 comments on commit 1e386ed

Please sign in to comment.