Author: ningjiang
Date: Thu Dec 10 12:26:43 2009
New Revision: 889234
URL: http://svn.apache.org/viewvc?rev=889234&view=rev
Log:
CAMEL-2275 Fixed the issue that camel-jpa JPAEndpoint eats up the cause of
InvalidPayloadException
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/InvalidPayloadRuntimeException.java
camel/trunk/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/InvalidPayloadRuntimeException.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/InvalidPayloadRuntimeException.java?rev=889234&r1=889233&r2=889234&view=diff
==============================================================================
---
camel/trunk/camel-core/src/main/java/org/apache/camel/InvalidPayloadRuntimeException.java
(original)
+++
camel/trunk/camel-core/src/main/java/org/apache/camel/InvalidPayloadRuntimeException.java
Thu Dec 10 12:26:43 2009
@@ -28,6 +28,10 @@
public InvalidPayloadRuntimeException(Exchange exchange, Class<?> type) {
this(exchange, type, exchange.getIn());
}
+
+ public InvalidPayloadRuntimeException(Exchange exchange, Class<?> type,
Throwable cause) {
+ this(exchange, type, exchange.getIn(), cause);
+ }
public InvalidPayloadRuntimeException(Exchange exchange, Class<?> type,
Message message) {
super("No body available of type: " + type.getName()
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=889234&r1=889233&r2=889234&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
Thu Dec 10 12:26:43 2009
@@ -265,7 +265,7 @@
answer =
exchange.getIn().getMandatoryBody(getEntityType());
}
} catch (InvalidPayloadException e) {
- throw new InvalidPayloadRuntimeException(exchange,
getEntityType());
+ throw new InvalidPayloadRuntimeException(exchange,
getEntityType(), e.getCause());
}
if (answer == null) {
