Skip to content

Commit

Permalink
Merge branch 'master' of github.com:sofastack/sofa-rpc into bugfix/co…
Browse files Browse the repository at this point in the history
…dec_classForName_perf2
  • Loading branch information
liujianjun.ljj committed Jan 2, 2023
2 parents eafabdd + 1e386ed commit 8d35559
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 8d35559

Please sign in to comment.