|
||||||||||
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.DefaultProducerTemplate
public class DefaultProducerTemplate
A client helper object (named like Spring's TransactionTemplate & JmsTemplate
et al) for working with Camel and sending Message
instances in an
Exchange
to an Endpoint
.
Constructor Summary | |
---|---|
DefaultProducerTemplate(CamelContext context)
|
|
DefaultProducerTemplate(CamelContext context,
Endpoint defaultEndpoint)
|
Method Summary | ||
---|---|---|
protected Processor |
createBodyAndHeaderProcessor(Object body,
String header,
Object headerValue)
|
|
protected Processor |
createBodyAndPropertyProcessor(Object body,
String property,
Object propertyValue)
|
|
protected Processor |
createSetBodyProcessor(Object body)
|
|
protected void |
doStart()
|
|
protected void |
doStop()
|
|
protected Object |
extractResultBody(Exchange result)
Extracts the body from the given result. |
|
protected Object |
extractResultBody(Exchange result,
ExchangePattern pattern)
Extracts the body from the given result. |
|
CamelContext |
getContext()
|
|
Endpoint |
getDefaultEndpoint()
|
|
protected Endpoint |
getMandatoryDefaultEndpoint()
|
|
Producer |
getProducer(Endpoint endpoint)
|
|
|
getResolvedEndpoint(String endpointUri,
Class<T> expectedClass)
|
|
protected boolean |
hasFaultMessage(Exchange result)
|
|
boolean |
isUseEndpointCache()
|
|
static DefaultProducerTemplate |
newInstance(CamelContext camelContext,
String defaultEndpointUri)
|
|
Exchange |
request(Endpoint endpoint,
Processor processor)
Sends an exchange to an endpoint using a supplied processor Uses an ExchangePattern.InOut message exchange pattern. |
|
Exchange |
request(String endpoint,
Processor processor)
Sends an exchange to an endpoint using a supplied processor Uses an ExchangePattern.InOut message exchange pattern. |
|
Object |
requestBody(Endpoint endpoint,
Object body)
Send the body to an endpoint returning any result output body. |
|
Object |
requestBody(Object body)
Sends the body to the default endpoint and returns the result content Uses an ExchangePattern.InOut message exchange pattern. |
|
Object |
requestBody(String endpoint,
Object body)
Send the body to an endpoint returning any result output body. |
|
Object |
requestBodyAndHeader(Endpoint endpoint,
Object body,
String header,
Object headerValue)
Send the body to an endpoint returning any result output body. |
|
Object |
requestBodyAndHeader(String endpoint,
Object body,
String header,
Object headerValue)
Send the body to an endpoint returning any result output body. |
|
Object |
requestBodyAndHeaders(Endpoint endpoint,
Object body,
Map<String,Object> headers)
Sends the body to an endpoint with the specified headers and header values. |
|
Object |
requestBodyAndHeaders(String endpointUri,
Object body,
Map<String,Object> headers)
Sends the body to an endpoint with the specified headers and header values. |
|
protected Endpoint |
resolveMandatoryEndpoint(String endpointUri)
|
|
Exchange |
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 |
|
Exchange |
send(Endpoint endpoint,
Processor processor)
Sends an exchange to an endpoint using a supplied processor |
|
Exchange |
send(Endpoint endpoint,
Processor processor,
AsyncCallback callback)
Sends an exchange to an endpoint using a supplied processor |
|
Exchange |
send(Exchange exchange)
Sends the exchange to the default endpoint |
|
Exchange |
send(Processor processor)
Sends an exchange to the default endpoint using a supplied processor |
|
Exchange |
send(String endpointUri,
Exchange exchange)
Sends the exchange to the given endpoint |
|
Exchange |
send(String endpointUri,
ExchangePattern pattern,
Processor processor)
Sends an exchange to an endpoint using a supplied processor |
|
Exchange |
send(String endpointUri,
Processor processor)
Sends an exchange to an endpoint using a supplied processor |
|
Exchange |
send(String endpointUri,
Processor processor,
AsyncCallback callback)
Sends an exchange to an endpoint using a supplied processor |
|
Object |
sendBody(Endpoint endpoint,
ExchangePattern pattern,
Object body)
Send the body to an endpoint with the given ExchangePattern
returning any result output body |
|
Object |
sendBody(Endpoint endpoint,
Object body)
Send the body to an endpoint returning any result output body |
|
Object |
sendBody(Object body)
Sends the body to the default endpoint and returns the result content |
|
Object |
sendBody(String endpointUri,
ExchangePattern pattern,
Object body)
Send the body to an endpoint returning any result output body |
|
Object |
sendBody(String endpointUri,
Object body)
Send the body to an endpoint returning any result output body |
|
Object |
sendBodyAndHeader(Endpoint endpoint,
ExchangePattern pattern,
Object body,
String header,
Object headerValue)
Sends the body to an endpoint with a specified header and header value |
|
Object |
sendBodyAndHeader(Endpoint endpoint,
Object body,
String header,
Object headerValue)
Sends the body to an endpoint with a specified header and header value |
|
Object |
sendBodyAndHeader(Object body,
String header,
Object headerValue)
Sends the body to the default endpoint with a specified header and header value |
|
Object |
sendBodyAndHeader(String endpoint,
ExchangePattern pattern,
Object body,
String header,
Object headerValue)
Sends the body to an endpoint with a specified header and header value |
|
Object |
sendBodyAndHeader(String endpointUri,
Object body,
String header,
Object headerValue)
Sends the body to an endpoint with a specified header and header value |
|
Object |
sendBodyAndHeaders(Endpoint endpoint,
ExchangePattern pattern,
Object body,
Map<String,Object> headers)
Sends the body to an endpoint with the specified headers and header values |
|
Object |
sendBodyAndHeaders(Endpoint endpoint,
Object body,
Map<String,Object> headers)
Sends the body to an endpoint with the specified headers and header values |
|
Object |
sendBodyAndHeaders(Object body,
Map<String,Object> headers)
Sends the body to the default endpoint with the specified headers and header values |
|
Object |
sendBodyAndHeaders(String endpointUri,
ExchangePattern pattern,
Object body,
Map<String,Object> headers)
Sends the body to an endpoint with the specified headers and header values |
|
Object |
sendBodyAndHeaders(String endpointUri,
Object body,
Map<String,Object> headers)
Sends the body to an endpoint with the specified headers and header values |
|
Object |
sendBodyAndProperty(Endpoint endpoint,
ExchangePattern pattern,
Object body,
String property,
Object propertyValue)
Sends the body to an endpoint with a specified property and property value |
|
Object |
sendBodyAndProperty(Endpoint endpoint,
Object body,
String property,
Object propertyValue)
Sends the body to an endpoint with a specified property and property value |
|
Object |
sendBodyAndProperty(Object body,
String property,
Object propertyValue)
Sends the body to the default endpoint with a specified property and property value |
|
Object |
sendBodyAndProperty(String endpoint,
ExchangePattern pattern,
Object body,
String property,
Object propertyValue)
Sends the body to an endpoint with a specified property and property value |
|
Object |
sendBodyAndProperty(String endpointUri,
Object body,
String property,
Object propertyValue)
Sends the body to an endpoint with a specified property and property value |
|
void |
setDefaultEndpoint(Endpoint defaultEndpoint)
|
|
void |
setDefaultEndpointUri(String endpointUri)
Sets the default endpoint to use if none is specified |
|
void |
setUseEndpointCache(boolean useEndpointCache)
|
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 |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Constructor Detail |
---|
public DefaultProducerTemplate(CamelContext context)
public DefaultProducerTemplate(CamelContext context, Endpoint defaultEndpoint)
Method Detail |
---|
public static DefaultProducerTemplate newInstance(CamelContext camelContext, String defaultEndpointUri)
public Exchange send(String endpointUri, Exchange exchange)
ProducerTemplate
send
in interface ProducerTemplate
endpointUri
- the endpoint URI to send the exchange toexchange
- the exchange to send
public Exchange send(String endpointUri, Processor processor)
ProducerTemplate
send
in interface ProducerTemplate
endpointUri
- the endpoint URI to send the exchange toprocessor
- the transformer used to populate the new exchange
Processor
to populate the exchange
public Exchange send(String endpointUri, Processor processor, AsyncCallback callback)
ProducerTemplate
send
in interface ProducerTemplate
endpointUri
- the endpoint URI to send the exchange toprocessor
- the transformer used to populate the new exchange
Processor
to populate the exchange.callback
- the callback will be called when the exchange is completed.
public Exchange send(String endpointUri, ExchangePattern pattern, Processor processor)
ProducerTemplate
send
in interface ProducerTemplate
endpointUri
- the endpoint URI to send the exchange topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
processor
- the transformer used to populate the new exchange
Processor
to populate the exchange
public Exchange send(Endpoint endpoint, Exchange exchange)
ProducerTemplate
send
in interface ProducerTemplate
endpoint
- the endpoint to send the exchange toexchange
- the exchange to send
public Exchange send(Endpoint endpoint, Processor processor)
ProducerTemplate
send
in interface ProducerTemplate
endpoint
- the endpoint to send the exchange toprocessor
- the transformer used to populate the new exchange
Processor
to populate the exchange
public Exchange send(Endpoint endpoint, Processor processor, AsyncCallback callback)
ProducerTemplate
send
in interface ProducerTemplate
endpoint
- the endpoint to send the exchange toprocessor
- the transformer used to populate the new exchange
Processor
to populate the exchange.callback
- the callback will be called when the exchange is completed.
public Exchange send(Endpoint endpoint, ExchangePattern pattern, Processor processor)
ProducerTemplate
send
in interface ProducerTemplate
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 exchange
Processor
to populate the exchange
public Object sendBody(Endpoint endpoint, ExchangePattern pattern, Object body)
ProducerTemplate
ExchangePattern
returning any result output body
sendBody
in interface ProducerTemplate
endpoint
- the endpoint to send the exchange topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
body
- the payload
public Object sendBody(Endpoint endpoint, Object body)
ProducerTemplate
sendBody
in interface ProducerTemplate
endpoint
- the endpoint to send the exchange tobody
- the payload
public Object sendBody(String endpointUri, Object body)
ProducerTemplate
sendBody
in interface ProducerTemplate
endpointUri
- the endpoint URI to send the exchange tobody
- the payload
public Object sendBody(String endpointUri, ExchangePattern pattern, Object body)
ProducerTemplate
sendBody
in interface ProducerTemplate
endpointUri
- the endpoint URI to send the exchange topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
body
- the payload
public Object sendBodyAndHeader(String endpointUri, Object body, String header, Object headerValue)
ProducerTemplate
sendBodyAndHeader
in interface ProducerTemplate
endpointUri
- the endpoint URI to send tobody
- the payload to sendheader
- the header nameheaderValue
- the header value
public Object sendBodyAndHeader(Endpoint endpoint, Object body, String header, Object headerValue)
ProducerTemplate
sendBodyAndHeader
in interface ProducerTemplate
endpoint
- the Endpoint to send tobody
- the payload to sendheader
- the header nameheaderValue
- the header value
public Object sendBodyAndHeader(Endpoint endpoint, ExchangePattern pattern, Object body, String header, Object headerValue)
ProducerTemplate
sendBodyAndHeader
in interface ProducerTemplate
endpoint
- the Endpoint to send topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
body
- the payload to sendheader
- the header nameheaderValue
- the header value
public Object sendBodyAndHeader(String endpoint, ExchangePattern pattern, Object body, String header, Object headerValue)
ProducerTemplate
sendBodyAndHeader
in interface ProducerTemplate
endpoint
- the Endpoint URI to send topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
body
- the payload to sendheader
- the header nameheaderValue
- the header value
public Object sendBodyAndProperty(String endpointUri, Object body, String property, Object propertyValue)
ProducerTemplate
sendBodyAndProperty
in interface ProducerTemplate
endpointUri
- the endpoint URI to send tobody
- the payload to sendproperty
- the property namepropertyValue
- the property value
public Object sendBodyAndProperty(Endpoint endpoint, Object body, String property, Object propertyValue)
ProducerTemplate
sendBodyAndProperty
in interface ProducerTemplate
endpoint
- the Endpoint to send tobody
- the payload to sendproperty
- the property namepropertyValue
- the property value
public Object sendBodyAndProperty(Endpoint endpoint, ExchangePattern pattern, Object body, String property, Object propertyValue)
ProducerTemplate
sendBodyAndProperty
in interface ProducerTemplate
endpoint
- the Endpoint to send topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
body
- the payload to sendproperty
- the property namepropertyValue
- the property value
public Object sendBodyAndProperty(String endpoint, ExchangePattern pattern, Object body, String property, Object propertyValue)
ProducerTemplate
sendBodyAndProperty
in interface ProducerTemplate
endpoint
- the Endpoint URI to send topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
body
- the payload to sendproperty
- the property namepropertyValue
- the property value
public Object sendBodyAndHeaders(String endpointUri, Object body, Map<String,Object> headers)
ProducerTemplate
sendBodyAndHeaders
in interface ProducerTemplate
endpointUri
- the endpoint URI to send tobody
- the payload to sendheaders
- headers
public Object sendBodyAndHeaders(Endpoint endpoint, Object body, Map<String,Object> headers)
ProducerTemplate
sendBodyAndHeaders
in interface ProducerTemplate
endpoint
- the endpoint URI to send tobody
- the payload to sendheaders
- headers
public Object sendBodyAndHeaders(String endpointUri, ExchangePattern pattern, Object body, Map<String,Object> headers)
ProducerTemplate
sendBodyAndHeaders
in interface ProducerTemplate
endpointUri
- the endpoint URI to send topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
body
- the payload to sendheaders
- headers
public Object sendBodyAndHeaders(Endpoint endpoint, ExchangePattern pattern, Object body, Map<String,Object> headers)
ProducerTemplate
sendBodyAndHeaders
in interface ProducerTemplate
endpoint
- the endpoint URI to send topattern
- the message ExchangePattern
such as
ExchangePattern.InOnly
or ExchangePattern.InOut
body
- the payload to sendheaders
- headers
public Exchange request(Endpoint endpoint, Processor processor)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
request
in interface ProducerTemplate
endpoint
- the Endpoint to send toprocessor
- the processor which will populate the exchange before sending
public Object requestBody(Object body)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
requestBody
in interface ProducerTemplate
body
- the payload to send
public Object requestBody(Endpoint endpoint, Object body)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
requestBody
in interface ProducerTemplate
endpoint
- the Endpoint to send tobody
- the payload
public Object requestBodyAndHeader(Endpoint endpoint, Object body, String header, Object headerValue)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
requestBodyAndHeader
in interface ProducerTemplate
endpoint
- the Endpoint to send tobody
- the payloadheader
- the header nameheaderValue
- the header value
public Exchange request(String endpoint, Processor processor)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
request
in interface ProducerTemplate
endpoint
- the endpoint URI to send toprocessor
- the processor which will populate the exchange before sending
public Object requestBody(String endpoint, Object body)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
requestBody
in interface ProducerTemplate
endpoint
- the endpoint URI to send tobody
- the payload
public Object requestBodyAndHeader(String endpoint, Object body, String header, Object headerValue)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
requestBodyAndHeader
in interface ProducerTemplate
endpoint
- the endpoint URI to send tobody
- the payloadheader
- the header nameheaderValue
- the header value
public Object requestBodyAndHeaders(String endpointUri, Object body, Map<String,Object> headers)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
requestBodyAndHeaders
in interface ProducerTemplate
endpointUri
- the endpoint URI to send tobody
- the payload to sendheaders
- headers
public Object requestBodyAndHeaders(Endpoint endpoint, Object body, Map<String,Object> headers)
ProducerTemplate
ExchangePattern.InOut
message exchange pattern.
requestBodyAndHeaders
in interface ProducerTemplate
endpoint
- the endpoint URI to send tobody
- the payload to sendheaders
- headers
public Object sendBody(Object body)
ProducerTemplate
sendBody
in interface ProducerTemplate
body
- the payload to send
public Exchange send(Exchange exchange)
ProducerTemplate
send
in interface ProducerTemplate
exchange
- the exchange to send
public Exchange send(Processor processor)
ProducerTemplate
send
in interface ProducerTemplate
processor
- the transformer used to populate the new exchange
Processor
to populate the exchange
public Object sendBodyAndHeader(Object body, String header, Object headerValue)
ProducerTemplate
sendBodyAndHeader
in interface ProducerTemplate
body
- the payload to sendheader
- the header nameheaderValue
- the header value
public Object sendBodyAndProperty(Object body, String property, Object propertyValue)
ProducerTemplate
sendBodyAndProperty
in interface ProducerTemplate
body
- the payload to sendproperty
- the property namepropertyValue
- the property value
public Object sendBodyAndHeaders(Object body, Map<String,Object> headers)
ProducerTemplate
sendBodyAndHeaders
in interface ProducerTemplate
body
- the payload to sendheaders
- the headers
public Producer getProducer(Endpoint endpoint)
public CamelContext getContext()
public Endpoint getDefaultEndpoint()
public void setDefaultEndpoint(Endpoint defaultEndpoint)
public void setDefaultEndpointUri(String endpointUri)
public boolean isUseEndpointCache()
public void setUseEndpointCache(boolean useEndpointCache)
public <T extends Endpoint> T getResolvedEndpoint(String endpointUri, Class<T> expectedClass)
protected Processor createBodyAndHeaderProcessor(Object body, String header, Object headerValue)
protected Processor createBodyAndPropertyProcessor(Object body, String property, Object propertyValue)
protected Processor createSetBodyProcessor(Object body)
protected Endpoint resolveMandatoryEndpoint(String endpointUri)
protected Endpoint getMandatoryDefaultEndpoint()
protected void doStart() throws Exception
doStart
in class ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class ServiceSupport
Exception
protected Object extractResultBody(Exchange result)
result
- the result
protected Object extractResultBody(Exchange result, ExchangePattern pattern)
result
- the resultpattern
- exchange pattern if given, can be null
protected boolean hasFaultMessage(Exchange result)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |