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:
AsyncProcessor, Navigate<Processor>, Processor, LoadBalancer, Service, ShutdownableService
Direct Known Subclasses:
FailOverLoadBalancer, QueueLoadBalancer, SimpleLoadBalancerSupport, TopicLoadBalancer

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

A default base class for a LoadBalancer implementation.

This implementation is dedicated for asynchronous load balancers.

Consider using the SimpleLoadBalancerSupport if your load balancer does not by nature support asynchronous routing.

Version:
$Revision: 20030 $

Field Summary
protected  org.apache.commons.logging.Log log
           
 
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 process(Exchange exchange)
          Processes the message exchange
 void removeProcessor(Processor processor)
          Removes the given processor from the load balancer
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, shutdown, 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.AsyncProcessor
process
 

Field Detail

log

protected final org.apache.commons.logging.Log log
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

process

public void process(Exchange exchange)
             throws Exception
Description copied from interface: Processor
Processes the message exchange

Specified by:
process in interface Processor
Parameters:
exchange - the message exchange
Throws:
Exception - if an internal processing error has occurred.


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