Skip to content
This repository was archived by the owner on Jun 21, 2023. It is now read-only.

Commit 62bcc34

Browse files
committed
Fixed tests
1 parent c56404a commit 62bcc34

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

services-gateway-benchmarks/src/main/java/io/scalecube/services/benchmarks/gateway/distributed/DistributedBenchmarkState.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,19 +38,19 @@ protected void beforeAll() throws Exception {
3838
.gateway(opts -> new RSocketGateway(opts.id("rsws")))
3939
.gateway(opts -> new WebsocketGateway(opts.id("ws")))
4040
.gateway(opts -> new HttpGateway(opts.id("http")))
41-
.discovery(ScalecubeServiceDiscovery::new)
41+
.discovery("gateway", ScalecubeServiceDiscovery::new)
4242
.transport(RSocketServiceTransport::new)
4343
.startAwait();
4444

45-
Address seedAddress = gateway.discovery().address();
45+
Address seedAddress = gateway.discovery("gateway").address();
4646
int numOfThreads = Runtime.getRuntime().availableProcessors();
4747
services =
4848
Microservices.builder()
4949
.discovery(
50+
"services",
5051
serviceEndpoint ->
5152
new ScalecubeServiceDiscovery(serviceEndpoint)
52-
.options(
53-
config -> config.membership(opts -> opts.seedMembers(seedAddress))))
53+
.membership(opts -> opts.seedMembers(seedAddress)))
5454
.transport(() -> new RSocketServiceTransport().numOfWorkers(numOfThreads))
5555
.services(new BenchmarkServiceImpl())
5656
.startAwait();

0 commit comments

Comments
 (0)