Updated Branches:
  refs/heads/camel-2.10.x a57455e3a -> ab76a81ad

CAMEL-6602 fix the ClassCastException when using cxf FailoverFeature


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9e7f2c67
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9e7f2c67
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9e7f2c67

Branch: refs/heads/camel-2.10.x
Commit: 9e7f2c67064a1b4939f5deefbd87fc82a8292f9b
Parents: a57455e
Author: Willem Jiang <ningji...@apache.org>
Authored: Tue Aug 6 07:36:17 2013 +0800
Committer: Willem Jiang <ningji...@apache.org>
Committed: Tue Aug 6 19:24:59 2013 +0800

----------------------------------------------------------------------
 .../main/java/org/apache/camel/component/cxf/CxfEndpoint.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/9e7f2c67/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
----------------------------------------------------------------------
diff --git 
a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
 
b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
index 2a328f9..20aef54 100644
--- 
a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
+++ 
b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
@@ -889,7 +889,9 @@ public class CxfEndpoint extends DefaultEndpoint implements 
HeaderFilterStrategy
                 message.remove(CxfConstants.CAMEL_CXF_ATTACHMENTS);
             }
 
-            if (DataFormat.PAYLOAD == message.get(DataFormat.class)) {
+            // Don't try to reset the parameters if the parameter is not 
CxfPayload instance
+            // as the setParameter will be called more than once when using 
the fail over feature
+            if (DataFormat.PAYLOAD == message.get(DataFormat.class) && 
params[0] instanceof CxfPayload) {
 
                 CxfPayload<?> payload = (CxfPayload<?>) params[0];
                 List<Source> elements = payload.getBodySources();

Reply via email to