diff --git a/akka-docs/src/test/java/jdocs/discovery/DnsDiscoveryDocTest.java b/akka-docs/src/test/java/jdocs/discovery/DnsDiscoveryDocTest.java index 80ffc9bf4f..9465cb7494 100644 --- a/akka-docs/src/test/java/jdocs/discovery/DnsDiscoveryDocTest.java +++ b/akka-docs/src/test/java/jdocs/discovery/DnsDiscoveryDocTest.java @@ -18,6 +18,7 @@ import org.scalatestplus.junit.JUnitSuite; import java.time.Duration; import java.util.concurrent.CompletionStage; +import java.util.concurrent.TimeUnit; @SuppressWarnings("unused") public class DnsDiscoveryDocTest extends JUnitSuite { @@ -42,7 +43,9 @@ public class DnsDiscoveryDocTest extends JUnitSuite { ServiceDiscovery discovery = Discovery.get(system).discovery(); // ... CompletionStage result = - discovery.lookup("akka.io", Duration.ofMillis(500)); + discovery.lookup("akka.io", Duration.ofSeconds(2)); // #lookup-dns + + result.toCompletableFuture().get(3, TimeUnit.SECONDS); } } diff --git a/akka-docs/src/test/scala/docs/discovery/DnsDiscoveryDocSpec.scala b/akka-docs/src/test/scala/docs/discovery/DnsDiscoveryDocSpec.scala index 4a3ace0c81..c49e408567 100644 --- a/akka-docs/src/test/scala/docs/discovery/DnsDiscoveryDocSpec.scala +++ b/akka-docs/src/test/scala/docs/discovery/DnsDiscoveryDocSpec.scala @@ -32,8 +32,9 @@ class DnsDiscoveryDocSpec extends AkkaSpec(DnsDiscoveryDocSpec.config) { val discovery: ServiceDiscovery = Discovery(system).discovery // ... - val result: Future[ServiceDiscovery.Resolved] = discovery.lookup("akka.io", resolveTimeout = 500.millis) + val result: Future[ServiceDiscovery.Resolved] = discovery.lookup("akka.io", resolveTimeout = 2.seconds) // #lookup-dns + val resolved = result.futureValue resolved.serviceName shouldBe "akka.io" resolved.addresses shouldNot be(Symbol("empty"))