You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/07/10 09:48:28 UTC
[camel] branch camel-2.21.x updated: CAMEL-12632: Pass CXF service
class to EndpointInfo
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-2.21.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.21.x by this push:
new 431ce99 CAMEL-12632: Pass CXF service class to EndpointInfo
431ce99 is described below
commit 431ce99c185f8465a68982ee2a20849c08c158e4
Author: Peter Palaga <pp...@redhat.com>
AuthorDate: Wed Jul 4 15:22:44 2018 +0200
CAMEL-12632: Pass CXF service class to EndpointInfo
---
.../src/main/java/org/apache/camel/component/cxf/CxfConsumer.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
index 1851c9c..73de640 100644
--- a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
+++ b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfConsumer.java
@@ -43,6 +43,7 @@ import org.apache.cxf.message.Message;
import org.apache.cxf.phase.Phase;
import org.apache.cxf.service.invoker.Invoker;
import org.apache.cxf.service.model.BindingOperationInfo;
+import org.apache.cxf.service.model.EndpointInfo;
import org.apache.cxf.transport.MessageObserver;
import org.apache.cxf.ws.addressing.ContextUtils;
import org.apache.cxf.ws.addressing.EndpointReferenceType;
@@ -76,6 +77,7 @@ public class CxfConsumer extends DefaultConsumer {
if (cxfEndpoint.getCxfEndpointConfigurer() != null) {
cxfEndpoint.getCxfEndpointConfigurer().configureServer(server);
}
+ server.getEndpoint().getEndpointInfo().setProperty("serviceClass", cxfEndpoint.getServiceClass());
if (ObjectHelper.isNotEmpty(cxfEndpoint.getPublishedEndpointUrl())) {
server.getEndpoint().getEndpointInfo().setProperty("publishedEndpointUrl", cxfEndpoint.getPublishedEndpointUrl());
}