|
||||||||||
| 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.impl.ProducerCache<E>
public class ProducerCache<E extends Exchange>
Cache containing created Producer.
| Constructor Summary | |
|---|---|
ProducerCache()
|
|
| Method Summary | |
|---|---|
protected void |
doStart()
|
protected void |
doStop()
|
Producer<E> |
getProducer(Endpoint<E> endpoint)
|
static boolean |
isProcessedSync(Exchange exchange)
|
void |
send(Endpoint<E> endpoint,
E exchange)
Sends the exchange to the given endpoint |
E |
send(Endpoint<E> endpoint,
ExchangePattern pattern,
Processor processor)
Sends an exchange to an endpoint using a supplied Processor to populate the exchange |
E |
send(Endpoint<E> endpoint,
Processor processor)
Sends an exchange to an endpoint using a supplied Processor to populate the exchange |
E |
send(Endpoint<E> endpoint,
Processor processor,
AsyncCallback callback)
Sends an exchange to an endpoint using a supplied Processor to populate the exchange. |
protected E |
sendExchange(Endpoint<E> endpoint,
Producer<E> producer,
Processor processor,
E exchange)
|
protected boolean |
sendExchange(Endpoint<E> endpoint,
Producer<E> producer,
Processor processor,
E exchange,
AsyncCallback callback)
|
static void |
setProcessedSync(Exchange exchange,
boolean b)
|
| 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 ProducerCache()
| Method Detail |
|---|
public Producer<E> getProducer(Endpoint<E> endpoint)
public void send(Endpoint<E> endpoint,
E exchange)
endpoint - the endpoint to send the exchange toexchange - the exchange to send
public E send(Endpoint<E> endpoint,
Processor processor)
Processor to populate the exchange
endpoint - the endpoint to send the exchange toprocessor - the transformer used to populate the new exchange
public E send(Endpoint<E> endpoint,
Processor processor,
AsyncCallback callback)
Processor to populate the exchange. The callback
will be called when the exchange is completed.
endpoint - the endpoint to send the exchange toprocessor - the transformer used to populate the new exchangepublic static boolean isProcessedSync(Exchange exchange)
public static void setProcessedSync(Exchange exchange,
boolean b)
public E send(Endpoint<E> endpoint,
ExchangePattern pattern,
Processor processor)
Processor to populate the exchange
endpoint - the endpoint to send the exchange topattern - the message ExchangePattern such as
ExchangePattern.InOnly or ExchangePattern.InOutprocessor - the transformer used to populate the new exchange
protected E sendExchange(Endpoint<E> endpoint,
Producer<E> producer,
Processor processor,
E exchange)
throws Exception
Exception
protected boolean sendExchange(Endpoint<E> endpoint,
Producer<E> producer,
Processor processor,
E exchange,
AsyncCallback callback)
throws Exception
Exception
protected void doStop()
throws Exception
doStop in class ServiceSupportException
protected void doStart()
throws Exception
doStart in class ServiceSupportException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||