diff --git a/rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/loadbalancer/RoundRobinRSocketLoadbalancerExample.java b/rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/loadbalancer/RoundRobinRSocketLoadbalancerExample.java index feafdb7a6..abed4a52d 100644 --- a/rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/loadbalancer/RoundRobinRSocketLoadbalancerExample.java +++ b/rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/loadbalancer/RoundRobinRSocketLoadbalancerExample.java @@ -97,7 +97,7 @@ public static void main(String[] args) { }); RSocketClient rSocketClient = - LoadbalanceRSocketClient.builder(producer).weightedLoadbalanceStrategy().build(); + LoadbalanceRSocketClient.builder(producer).roundRobinLoadbalanceStrategy().build(); for (int i = 0; i < 10000; i++) { try {