|
||||||||||
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
public class ProducerCache
Cache containing created Producer
.
Constructor Summary | |
---|---|
ProducerCache()
|
Method Summary | |
---|---|
protected void |
doStart()
|
protected void |
doStop()
|
Producer |
getProducer(Endpoint endpoint)
|
static boolean |
isProcessedSync(Exchange exchange)
|
void |
send(Endpoint endpoint,
Exchange exchange)
Sends the exchange to the given endpoint |
Exchange |
send(Endpoint endpoint,
ExchangePattern pattern,
Processor processor)
Sends an exchange to an endpoint using a supplied Processor to populate the exchange |
Exchange |
send(Endpoint endpoint,
Processor processor)
Sends an exchange to an endpoint using a supplied Processor to populate the exchange |
Exchange |
send(Endpoint endpoint,
Processor processor,
AsyncCallback callback)
Sends an exchange to an endpoint using a supplied Processor to populate the exchange. |
protected Exchange |
sendExchange(Endpoint endpoint,
Producer producer,
Processor processor,
Exchange exchange)
|
protected boolean |
sendExchange(Endpoint endpoint,
Producer producer,
Processor processor,
Exchange exchange,
AsyncCallback callback)
|
static void |
setProcessedSync(Exchange exchange,
boolean sync)
|
Methods inherited from class org.apache.camel.impl.ServiceSupport |
---|
addChildService, getStatus, getThreadName, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, nextThreadCounter, notStarting, 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 getProducer(Endpoint endpoint)
public void send(Endpoint endpoint, Exchange exchange)
endpoint
- the endpoint to send the exchange toexchange
- the exchange to sendpublic Exchange send(Endpoint endpoint, Processor processor)
Processor
to populate the exchange
endpoint
- the endpoint to send the exchange toprocessor
- the transformer used to populate the new exchangepublic Exchange send(Endpoint 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 sync)
public Exchange send(Endpoint 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.InOut
processor
- the transformer used to populate the new exchangeprotected Exchange sendExchange(Endpoint endpoint, Producer producer, Processor processor, Exchange exchange) throws Exception
Exception
protected boolean sendExchange(Endpoint endpoint, Producer producer, Processor processor, Exchange exchange, AsyncCallback callback) throws Exception
Exception
protected void doStop() throws Exception
doStop
in class ServiceSupport
Exception
protected void doStart() throws Exception
doStart
in class ServiceSupport
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |