Minor API cleanup: load-balancer algorithm constructors usage of generics was too restrictive.
| | |
| | | private ScheduledFuture<?> monitoringFuture; |
| | | private AtomicBoolean isClosed = new AtomicBoolean(); |
| | | |
| | | AbstractLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | AbstractLoadBalancingAlgorithm(final Collection<? extends ConnectionFactory> factories, |
| | | final LoadBalancerEventListener listener, final long interval, final TimeUnit unit, |
| | | final ScheduledExecutorService scheduler) { |
| | | Validator.ensureNotNull(factories, unit); |
| | |
| | | * @param factories |
| | | * The ordered collection of connection factories. |
| | | */ |
| | | public FailoverLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories) { |
| | | public FailoverLoadBalancingAlgorithm(final Collection<? extends ConnectionFactory> factories) { |
| | | this(factories, null, 1, TimeUnit.SECONDS, null); |
| | | } |
| | | |
| | |
| | | * connection factory changes state from online to offline or |
| | | * vice-versa. |
| | | */ |
| | | public FailoverLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | public FailoverLoadBalancingAlgorithm(final Collection<? extends ConnectionFactory> factories, |
| | | final LoadBalancerEventListener listener) { |
| | | this(factories, listener, 1, TimeUnit.SECONDS, null); |
| | | } |
| | |
| | | * The time unit for the interval between attempts to poll |
| | | * offline factories. |
| | | */ |
| | | public FailoverLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | public FailoverLoadBalancingAlgorithm(final Collection<? extends ConnectionFactory> factories, |
| | | final LoadBalancerEventListener listener, final long interval, final TimeUnit unit) { |
| | | this(factories, listener, interval, unit, null); |
| | | } |
| | |
| | | * The scheduler which should for periodically monitoring dead |
| | | * connection factories to see if they are usable again. |
| | | */ |
| | | public FailoverLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | public FailoverLoadBalancingAlgorithm(final Collection<? extends ConnectionFactory> factories, |
| | | final LoadBalancerEventListener listener, final long interval, final TimeUnit unit, |
| | | final ScheduledExecutorService scheduler) { |
| | | super(factories, listener, interval, unit, scheduler); |
| | |
| | | * The time unit for the interval between attempts to poll |
| | | * offline factories. |
| | | */ |
| | | public FailoverLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | public FailoverLoadBalancingAlgorithm(final Collection<? extends ConnectionFactory> factories, |
| | | final long interval, final TimeUnit unit) { |
| | | this(factories, null, interval, unit, null); |
| | | } |
| | |
| | | * The scheduler which should for periodically monitoring dead |
| | | * connection factories to see if they are usable again. |
| | | */ |
| | | public FailoverLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | public FailoverLoadBalancingAlgorithm(final Collection<? extends ConnectionFactory> factories, |
| | | final long interval, final TimeUnit unit, final ScheduledExecutorService scheduler) { |
| | | this(factories, null, interval, unit, scheduler); |
| | | } |
| | |
| | | * @param factories |
| | | * The ordered collection of connection factories. |
| | | */ |
| | | public RoundRobinLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories) { |
| | | public RoundRobinLoadBalancingAlgorithm(final Collection<? extends ConnectionFactory> factories) { |
| | | this(factories, null, 1, TimeUnit.SECONDS, null); |
| | | } |
| | | |
| | |
| | | * connection factory changes state from online to offline or |
| | | * vice-versa. |
| | | */ |
| | | public RoundRobinLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | public RoundRobinLoadBalancingAlgorithm( |
| | | final Collection<? extends ConnectionFactory> factories, |
| | | final LoadBalancerEventListener listener) { |
| | | this(factories, listener, 1, TimeUnit.SECONDS, null); |
| | | } |
| | |
| | | * The time unit for the interval between attempts to poll |
| | | * offline factories. |
| | | */ |
| | | public RoundRobinLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | public RoundRobinLoadBalancingAlgorithm( |
| | | final Collection<? extends ConnectionFactory> factories, |
| | | final LoadBalancerEventListener listener, final long interval, final TimeUnit unit) { |
| | | this(factories, null, interval, unit, null); |
| | | } |
| | |
| | | * The scheduler which should for periodically monitoring dead |
| | | * connection factories to see if they are usable again. |
| | | */ |
| | | public RoundRobinLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | public RoundRobinLoadBalancingAlgorithm( |
| | | final Collection<? extends ConnectionFactory> factories, |
| | | final LoadBalancerEventListener listener, final long interval, final TimeUnit unit, |
| | | final ScheduledExecutorService scheduler) { |
| | | super(factories, listener, interval, unit, scheduler); |
| | |
| | | * The time unit for the interval between attempts to poll |
| | | * offline factories. |
| | | */ |
| | | public RoundRobinLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | final long interval, final TimeUnit unit) { |
| | | public RoundRobinLoadBalancingAlgorithm( |
| | | final Collection<? extends ConnectionFactory> factories, final long interval, |
| | | final TimeUnit unit) { |
| | | this(factories, null, interval, unit, null); |
| | | } |
| | | |
| | |
| | | * The scheduler which should for periodically monitoring dead |
| | | * connection factories to see if they are usable again. |
| | | */ |
| | | public RoundRobinLoadBalancingAlgorithm(final Collection<ConnectionFactory> factories, |
| | | final long interval, final TimeUnit unit, final ScheduledExecutorService scheduler) { |
| | | public RoundRobinLoadBalancingAlgorithm( |
| | | final Collection<? extends ConnectionFactory> factories, final long interval, |
| | | final TimeUnit unit, final ScheduledExecutorService scheduler) { |
| | | this(factories, null, interval, unit, scheduler); |
| | | } |
| | | |