Use retryWhen() in StatsdMeterRegistry (#1946)

micrometer-metrics · Mar 27, 2020 · 618f5b9 · 618f5b9
1 parent 2fbd655
commit 618f5b9
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...ns/micrometer-registry-statsd/src/main/java/io/micrometer/statsd/StatsdMeterRegistry.java b/...ns/micrometer-registry-statsd/src/main/java/io/micrometer/statsd/StatsdMeterRegistry.java
@@ -37,6 +37,7 @@
 import reactor.netty.tcp.TcpClient;
 import reactor.netty.udp.UdpClient;
 import reactor.util.context.Context;
+import reactor.util.retry.Retry;
 
 import java.net.PortUnreachableException;
 import java.time.Duration;
@@ -223,7 +224,7 @@ private void prepareUdpClient(Publisher<String> publisher) {
                 .handle((in, out) -> out
                         .sendString(publisher)
                         .neverComplete()
-                        .retry(throwable -> throwable instanceof PortUnreachableException)
+                        .retryWhen(Retry.indefinitely().filter(throwable -> throwable instanceof PortUnreachableException))
                 )
                 .connect()
                 .subscribe(client -> {
@@ -254,7 +255,7 @@ private void connectAndSubscribe(TcpClient tcpClient) {
             }
             return Mono.empty();
         })
-                .retryBackoff(Long.MAX_VALUE, Duration.ofSeconds(1), Duration.ofMinutes(1))
+                .retryWhen(Retry.backoff(Long.MAX_VALUE, Duration.ofSeconds(1)).maxBackoff(Duration.ofMinutes(1)))
                 .subscribe(client -> {
                     this.client.replace(client);