org.apache.camel.processor.loadbalancer
Class LoadBalancerSupport

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.processor.loadbalancer.LoadBalancerSupport
All Implemented Interfaces:
Navigate<Processor>, Processor, LoadBalancer, Service
Direct Known Subclasses:
FailOverLoadBalancer, QueueLoadBalancer, TopicLoadBalancer

public abstract class LoadBalancerSupport
extends ServiceSupport
implements LoadBalancer, Navigate<Processor>

A default base class for a LoadBalancer implementation

Version:
$Revision: 15303 $

Constructor Summary
LoadBalancerSupport()
           
 
Method Summary
 void addProcessor(Processor processor)
          Adds a new processor to the load balancer
protected  void doStart()
           
protected  void doStop()
           
 List<Processor> getProcessors()
          Returns the current processors available to this load balancer
 boolean hasNext()
          Are there more outputs?
 List<Processor> next()
          Next group of outputs
 void removeProcessor(Processor processor)
          Removes the given processor from the load balancer
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Processor
process
 

Constructor Detail

LoadBalancerSupport

public LoadBalancerSupport()
Method Detail

addProcessor

public void addProcessor(Processor processor)
Description copied from interface: LoadBalancer
Adds a new processor to the load balancer

Specified by:
addProcessor in interface LoadBalancer
Parameters:
processor - the processor to be added to the load balancer

removeProcessor

public void removeProcessor(Processor processor)
Description copied from interface: LoadBalancer
Removes the given processor from the load balancer

Specified by:
removeProcessor in interface LoadBalancer
Parameters:
processor - the processor to be removed from the load balancer

getProcessors

public List<Processor> getProcessors()
Description copied from interface: LoadBalancer
Returns the current processors available to this load balancer

Specified by:
getProcessors in interface LoadBalancer
Returns:
the processors available

next

public List<Processor> next()
Description copied from interface: Navigate
Next group of outputs

Specified by:
next in interface Navigate<Processor>
Returns:
next group or null if no more outputs

hasNext

public boolean hasNext()
Description copied from interface: Navigate
Are there more outputs?

Specified by:
hasNext in interface Navigate<Processor>
Returns:
true if more outputs

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class ServiceSupport
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Specified by:
doStop in class ServiceSupport
Throws:
Exception


Copyright © 2007-2010 IONA Open Source Community. All Rights Reserved.