This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit dd4a715fce31ed4f9407520f52c18b77e1d65322 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Aug 30 22:24:12 2021 +0200 CAMEL-16863: camel-spring-ws - The created exchange should be InOut --- .../org/apache/camel/component/spring/ws/SpringWebserviceConsumer.java | 3 --- .../org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java | 3 +++ 2 files changed, 3 insertions(+), 3 deletions(-) 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 abebef4..90fff58 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 @@ -27,7 +27,6 @@ import javax.xml.transform.Source; import org.apache.camel.Endpoint; import org.apache.camel.Exchange; -import org.apache.camel.ExchangePattern; import org.apache.camel.ExtendedExchange; import org.apache.camel.Message; import org.apache.camel.Processor; @@ -63,7 +62,6 @@ public class SpringWebserviceConsumer extends DefaultConsumer implements Message public void invoke(MessageContext messageContext) throws Exception { Exchange exchange = createExchange(false); try { - exchange.setPattern(ExchangePattern.InOptionalOut); populateExchangeFromMessageContext(messageContext, exchange); // populate camel exchange with breadcrumb from transport header @@ -189,7 +187,6 @@ public class SpringWebserviceConsumer extends DefaultConsumer implements Message SoapHeaderElement element = elementIter.next(); QName name = element.getName(); headers.put(name.getLocalPart(), element); - } } } diff --git a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java index 5d9f387..004cf95 100644 --- a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java +++ b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java @@ -19,6 +19,7 @@ package org.apache.camel.component.spring.ws; import org.apache.camel.Category; import org.apache.camel.Component; import org.apache.camel.Consumer; +import org.apache.camel.ExchangePattern; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.spi.UriEndpoint; @@ -39,6 +40,7 @@ public class SpringWebserviceEndpoint extends DefaultEndpoint { public SpringWebserviceEndpoint(Component component, String uri, SpringWebserviceConfiguration configuration) { super(uri, component); this.configuration = configuration; + setExchangePattern(ExchangePattern.InOut); } @Override @@ -59,4 +61,5 @@ public class SpringWebserviceEndpoint extends DefaultEndpoint { public SpringWebserviceConfiguration getConfiguration() { return configuration; } + }
