org.apache.camel.processor.loadbalancer
Class TopicLoadBalancer
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.processor.loadbalancer.LoadBalancerSupport
org.apache.camel.processor.loadbalancer.TopicLoadBalancer
- All Implemented Interfaces:
- Processor, LoadBalancer, Service
public class TopicLoadBalancer
- extends LoadBalancerSupport
A LoadBalancer
implementations which sends to all destinations
(rather like JMS Topics)
- Version:
- $Revision: 36635 $
Methods inherited from class org.apache.camel.impl.ServiceSupport |
addChildService, getThreadName, isRunAllowed, isStarted, isStarting, isStopped, isStopping, nextThreadCounter, removeChildService, start, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TopicLoadBalancer
public TopicLoadBalancer()
process
public void process(Exchange exchange)
throws Exception
- Description copied from interface:
Processor
- Processes the message exchange
- Throws:
Exception
- if an internal processing error has occurred.
copyExchangeStrategy
protected Exchange copyExchangeStrategy(Processor processor,
Exchange exchange)
- Strategy method to copy the exchange before sending to another endpoint.
Derived classes such as the
Pipeline
will not clone the exchange
- Parameters:
processor
- the processor that will send the exchangeexchange
- the exchange
- Returns:
- the current exchange if no copying is required such as for a
pipeline otherwise a new copy of the exchange is returned.
Copyright © 2008 IONA Open Source Community. All Rights Reserved.