|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.camel.impl.ServiceSupport
org.apache.camel.processor.loadbalancer.LoadBalancerSupport
org.apache.camel.processor.loadbalancer.TopicLoadBalancer
public class TopicLoadBalancer
A LoadBalancer
implementations which sends to all destinations
(rather like JMS Topics).
It is deprecated in Camel 2.0, you need to move to use multicast,
if you want to send the message to all destinations.
Constructor Summary | |
---|---|
TopicLoadBalancer()
Deprecated. |
Method Summary | |
---|---|
protected Exchange |
copyExchangeStrategy(Processor processor,
Exchange exchange)
Deprecated. Strategy method to copy the exchange before sending to another endpoint. |
void |
process(Exchange exchange)
Deprecated. Processes the message exchange |
boolean |
process(Exchange exchange,
AsyncCallback callback)
Deprecated. Processes the message exchange. |
Methods inherited from class org.apache.camel.processor.loadbalancer.LoadBalancerSupport |
---|
addProcessor, doStart, doStop, getProcessors, removeProcessor |
Methods inherited from class org.apache.camel.impl.ServiceSupport |
---|
addChildService, getThreadName, getVersion, 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 |
Constructor Detail |
---|
public TopicLoadBalancer()
Method Detail |
---|
public void process(Exchange exchange) throws Exception
Processor
Exception
- if an internal processing error has occurred.protected Exchange copyExchangeStrategy(Processor processor, Exchange exchange)
Pipeline
will not clone the exchange
processor
- the processor that will send the exchangeexchange
- the exchange
public boolean process(Exchange exchange, AsyncCallback callback)
AsyncProcessor
Processor.process(org.apache.camel.Exchange)
, but
the caller supports having the exchange asynchronously processed.
exchange
- the Exchange
to processcallback
- the AsyncCallback
will be invoked when the processing
of the exchange is completed. If the exchange is completed synchronously, then the
callback is also invoked synchronously. The callback should therefore be careful of
starting recursive loop.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |