Package akka.discovery.aggregate
Class AggregateServiceDiscovery
- java.lang.Object
-
- akka.discovery.ServiceDiscovery
-
- akka.discovery.aggregate.AggregateServiceDiscovery
-
public final class AggregateServiceDiscovery extends ServiceDiscovery
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.discovery.ServiceDiscovery
ServiceDiscovery.DiscoveryTimeoutException, ServiceDiscovery.Resolved, ServiceDiscovery.Resolved$, ServiceDiscovery.ResolvedTarget, ServiceDiscovery.ResolvedTarget$
-
-
Constructor Summary
Constructors Constructor Description AggregateServiceDiscovery(ExtendedActorSystem system)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.concurrent.Future<ServiceDiscovery.Resolved>
lookup(Lookup lookup, scala.concurrent.duration.FiniteDuration resolveTimeout)
Each discovery method is given the resolveTimeout rather than reducing it each time between methods.-
Methods inherited from class akka.discovery.ServiceDiscovery
lookup, lookup, lookup
-
-
-
-
Constructor Detail
-
AggregateServiceDiscovery
public AggregateServiceDiscovery(ExtendedActorSystem system)
-
-
Method Detail
-
lookup
public scala.concurrent.Future<ServiceDiscovery.Resolved> lookup(Lookup lookup, scala.concurrent.duration.FiniteDuration resolveTimeout)
Each discovery method is given the resolveTimeout rather than reducing it each time between methods.- Specified by:
lookup
in classServiceDiscovery
- Parameters:
lookup
- A service discovery lookup.resolveTimeout
- Timeout. Up to the discovery-method to adhere to his- Returns:
- Resolved future should be failed with a [DiscoveryTimeoutException] if the
resolveTimeout
is exceeded.
-
-