org.apache.tephra.distributed

Class AbstractClientProvider.TimeLimitEndpointStrategy

java.lang.Object

org.apache.tephra.distributed.AbstractClientProvider.TimeLimitEndpointStrategy

All Implemented Interfaces:

AbstractClientProvider.EndpointStrategy

Enclosing class:

AbstractClientProvider

public final class AbstractClientProvider.TimeLimitEndpointStrategy
extends Object
implements AbstractClientProvider.EndpointStrategy

An AbstractClientProvider.EndpointStrategy that make sure it picks an endpoint within the given timeout limit.

Constructor Summary

Constructors

Constructor and Description
TimeLimitEndpointStrategy(AbstractClientProvider.EndpointStrategy delegate, long timeout, TimeUnit timeoutUnit)

Method Summary

Modifier and Type	Method and Description
org.apache.twill.discovery.Discoverable	pick() Picks a Discoverable using its strategy.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TimeLimitEndpointStrategy

public TimeLimitEndpointStrategy(AbstractClientProvider.EndpointStrategy delegate,
                                 long timeout,
                                 TimeUnit timeoutUnit)

Method Detail

pick

public org.apache.twill.discovery.Discoverable pick()

Description copied from interface: AbstractClientProvider.EndpointStrategy

Picks a Discoverable using its strategy.

Specified by:

pick in interface AbstractClientProvider.EndpointStrategy

Returns:

A Discoverable based on the stragegy or null if no endpoint can be found.