update the duration type to reflect change in asynchttpclient

confluentinc · Dec 12, 2024 · 0292154 · 0292154
1 parent 47e4bc1
commit 0292154
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/core/src/test/java/io/confluent/rest/CustomInitTest.java b/core/src/test/java/io/confluent/rest/CustomInitTest.java
@@ -27,6 +27,7 @@
 import java.util.Properties;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Consumer;
+import java.time.Duration;
 import javax.websocket.EndpointConfig;
 import javax.websocket.OnOpen;
 import javax.websocket.Session;
@@ -143,7 +144,7 @@ public void onError(Throwable t) {
 
     WebSocket ws = Dsl.asyncHttpClient()
         .prepareGet(uri + "/test")
-        .setRequestTimeout(10000)
+        .setRequestTimeout(Duration.ofSeconds(10000))
         .execute(wsHandler)
         .get();
 

diff --git a/core/src/test/java/io/confluent/rest/SaslTest.java b/core/src/test/java/io/confluent/rest/SaslTest.java
@@ -52,6 +52,7 @@
 import java.util.Collections;
 import java.util.Map;
 import java.util.Properties;
+import java.time.Duration;
 
 import javax.security.auth.login.Configuration;
 import javax.ws.rs.GET;
@@ -283,7 +284,7 @@ public void onError(Throwable t) {
     }
 
     WebSocket ws = requestBuilder
-        .setRequestTimeout(10000)
+        .setRequestTimeout(Duration.ofSeconds(10000))
         .execute(wsHandler)
         .get();