From f404f3eb286550e0ea41a1efdec26206c108cc97 Mon Sep 17 00:00:00 2001 From: Oleh Dokuka Date: Tue, 27 Oct 2020 15:09:24 +0200 Subject: [PATCH] fixes to use round-robin strategy Signed-off-by: Oleh Dokuka --- .../tcp/loadbalancer/RoundRobinRSocketLoadbalancerExample.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 {