com.garethahealy.camel.dynamic.loadbalancer.core

Class DynamicWeightedRoundRobinLoadBalancer

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.processor.loadbalancer.LoadBalancerSupport

org.apache.camel.processor.loadbalancer.QueueLoadBalancer

org.apache.camel.processor.loadbalancer.WeightedLoadBalancer

org.apache.camel.processor.loadbalancer.WeightedRoundRobinLoadBalancer

com.garethahealy.camel.dynamic.loadbalancer.core.DynamicWeightedRoundRobinLoadBalancer

All Implemented Interfaces:

org.apache.camel.AsyncProcessor, org.apache.camel.Navigate<org.apache.camel.Processor>, org.apache.camel.Processor, org.apache.camel.processor.loadbalancer.LoadBalancer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.spi.IdAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class DynamicWeightedRoundRobinLoadBalancer
extends org.apache.camel.processor.loadbalancer.WeightedRoundRobinLoadBalancer

Dynamic load balancer that updates the runtime ratios based on metrics

Field Summary

Fields inherited from class org.apache.camel.processor.loadbalancer.LoadBalancerSupport

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
DynamicWeightedRoundRobinLoadBalancer(DynamicLoadBalancerConfiguration config)

Method Summary

Modifier and Type	Method and Description
protected org.apache.camel.Processor	chooseProcessor(List<org.apache.camel.Processor> processors, org.apache.camel.Exchange exchange)
protected void	doStart()
String	toString()

Methods inherited from class org.apache.camel.processor.loadbalancer.WeightedLoadBalancer

deepCloneDistributionRatios, getDistributionRatioList, getLastChosenProcessorIndex, getRuntimeRatios, isRuntimeRatiosZeroed, loadRuntimeRatios, resetRuntimeRatios, setDistributionRatioList, setRuntimeRatios

Methods inherited from class org.apache.camel.processor.loadbalancer.QueueLoadBalancer

process

Methods inherited from class org.apache.camel.processor.loadbalancer.LoadBalancerSupport

addProcessor, doShutdown, doStop, getId, getProcessors, hasNext, next, process, removeProcessor, setId

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicWeightedRoundRobinLoadBalancer

public DynamicWeightedRoundRobinLoadBalancer(DynamicLoadBalancerConfiguration config)

Method Detail

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.apache.camel.processor.loadbalancer.WeightedLoadBalancer

Throws:

Exception

chooseProcessor

protected org.apache.camel.Processor chooseProcessor(List<org.apache.camel.Processor> processors,
                                                     org.apache.camel.Exchange exchange)

Overrides:

chooseProcessor in class org.apache.camel.processor.loadbalancer.WeightedRoundRobinLoadBalancer

toString

public String toString()

Overrides:

toString in class Object