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 2017/02/27 10:19:21 UTC
[2/9] camel git commit: CAMEL-10888 - handling in exchange pattern
CAMEL-10888 - handling in exchange pattern
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7cd375e0
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7cd375e0
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7cd375e0
Branch: refs/heads/camel-2.18.x
Commit: 7cd375e0d4adf36da1840fc3f1c969bfa8586bce
Parents: c88814f
Author: onders86 <on...@gmail.com>
Authored: Fri Feb 24 16:17:42 2017 +0300
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Feb 27 10:31:21 2017 +0100
----------------------------------------------------------------------
.../spring/ws/SpringWebserviceConsumer.java | 19 +++++++++----------
1 file changed, 9 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/7cd375e0/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceConsumer.java b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceConsumer.java
index dd964bd..54ac6ff 100644
--- a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceConsumer.java
+++ b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceConsumer.java
@@ -57,21 +57,20 @@ public class SpringWebserviceConsumer extends DefaultConsumer implements Message
// start message processing
getProcessor().process(exchange);
- Message responseMessage = null;
- Source responseBody = null;
+
if (exchange.getException() != null) {
throw exchange.getException();
} else {
- responseMessage = exchange.hasOut() ? exchange.getOut(Message.class) : exchange.getIn(Message.class);
- }
- if (responseMessage != null) {
- responseBody = responseMessage.getBody(Source.class);
- WebServiceMessage response = messageContext.getResponse();
+ Message responseMessage = exchange.hasOut() ? exchange.getOut(Message.class) : exchange.getIn(Message.class);
+ if (responseMessage != null) {
+ Source responseBody = responseMessage.getBody(Source.class);
+ WebServiceMessage response = messageContext.getResponse();
- configuration.getMessageFilter().filterConsumer(exchange, response);
+ configuration.getMessageFilter().filterConsumer(exchange, response);
- XmlConverter xmlConverter = configuration.getXmlConverter();
- xmlConverter.toResult(responseBody, response.getPayloadResult());
+ XmlConverter xmlConverter = configuration.getXmlConverter();
+ xmlConverter.toResult(responseBody, response.getPayloadResult());
+ }
}
}