You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/06/24 07:37:22 UTC
svn commit: r787911 - in
/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa:
JpaEndpoint.java JpaProducer.java
Author: davsclaus
Date: Wed Jun 24 05:37:21 2009
New Revision: 787911
URL: http://svn.apache.org/viewvc?rev=787911&view=rev
Log:
CAMEL-1735: Fixed camel-example-etl using type converter not having default no arg ctr. Introduced JpaTemplate as a header from camel-jpa in case you need it.
Modified:
camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java
Modified: camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java?rev=787911&r1=787910&r2=787911&view=diff
==============================================================================
--- camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java (original)
+++ camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java Wed Jun 24 05:37:21 2009
@@ -259,7 +259,6 @@
} else {
return new ExpressionAdapter() {
public Object evaluate(Exchange exchange) {
- exchange.getIn().setHeader(JpaConstants.JPA_TEMPLATE, getTemplate());
Object answer = exchange.getIn().getBody(type);
if (answer == null) {
Object defaultValue = exchange.getIn().getBody();
Modified: camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java?rev=787911&r1=787910&r2=787911&view=diff
==============================================================================
--- camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java (original)
+++ camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java Wed Jun 24 05:37:21 2009
@@ -43,6 +43,7 @@
}
public void process(Exchange exchange) {
+ exchange.getIn().setHeader(JpaConstants.JPA_TEMPLATE, endpoint.getTemplate());
final Object values = expression.evaluate(exchange, Object.class);
if (values != null) {
template.execute(new JpaCallback() {
@@ -59,5 +60,6 @@
}
});
}
+ exchange.getIn().removeHeader(JpaConstants.JPA_TEMPLATE);
}
}