com.garethahealy.camel.dynamic.loadbalancer.core

Class DynamicRoundRobinLoadBalancer

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.RoundRobinLoadBalancer

com.garethahealy.camel.dynamic.loadbalancer.core.DynamicRoundRobinLoadBalancer

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 DynamicRoundRobinLoadBalancer
extends org.apache.camel.processor.loadbalancer.RoundRobinLoadBalancer

Dynamic load balancer that selects a processor based on metrics, else fallback to default round-robin

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
DynamicRoundRobinLoadBalancer(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)
String	toString()

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

getLastChosenProcessorIndex

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

process

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

addProcessor, doShutdown, doStart, 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

DynamicRoundRobinLoadBalancer

public DynamicRoundRobinLoadBalancer(DynamicLoadBalancerConfiguration config)

Method Detail

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.RoundRobinLoadBalancer

toString

public String toString()

Overrides:

toString in class org.apache.camel.processor.loadbalancer.RoundRobinLoadBalancer