You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2013/07/25 04:52:02 UTC
git commit: CAMEL-6570 send the CLIENT_CREATED when creating the
client in CXFEndpoint
Updated Branches:
refs/heads/master f6f6b78a9 -> 10b08ab05
CAMEL-6570 send the CLIENT_CREATED when creating the client in CXFEndpoint
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/10b08ab0
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/10b08ab0
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/10b08ab0
Branch: refs/heads/master
Commit: 10b08ab054be1d744145afa20375128e7134ff3a
Parents: f6f6b78
Author: Willem Jiang <ni...@apache.org>
Authored: Thu Jul 25 10:42:15 2013 +0800
Committer: Willem Jiang <ni...@apache.org>
Committed: Thu Jul 25 10:42:45 2013 +0800
----------------------------------------------------------------------
.../org/apache/camel/component/cxf/CxfEndpoint.java | 13 ++++++++++---
1 file changed, 10 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/10b08ab0/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 23a6ce7..156aec3 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
@@ -91,6 +91,7 @@ import org.apache.cxf.message.MessageContentsList;
import org.apache.cxf.resource.DefaultResourceManager;
import org.apache.cxf.resource.ResourceManager;
import org.apache.cxf.resource.ResourceResolver;
+import org.apache.cxf.service.factory.FactoryBeanListener;
import org.apache.cxf.service.factory.ReflectionServiceFactoryBean;
import org.apache.cxf.service.model.BindingOperationInfo;
import org.apache.cxf.service.model.MessagePartInfo;
@@ -343,14 +344,18 @@ public class CxfEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
return new JaxWsClientFactoryBean() {
@Override
protected Client createClient(Endpoint ep) {
- return new CamelCxfClientImpl(getBus(), ep);
+ Client client = new CamelCxfClientImpl(getBus(), ep);
+ this.getServiceFactory().sendEvent(FactoryBeanListener.Event.CLIENT_CREATED, client, ep);
+ return client;
}
};
} else {
return new ClientFactoryBean() {
@Override
protected Client createClient(Endpoint ep) {
- return new CamelCxfClientImpl(getBus(), ep);
+ Client client = new CamelCxfClientImpl(getBus(), ep);
+ this.getServiceFactory().sendEvent(FactoryBeanListener.Event.CLIENT_CREATED, client, ep);
+ return client;
}
};
}
@@ -364,7 +369,9 @@ public class CxfEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
@Override
protected Client createClient(Endpoint ep) {
- return new CamelCxfClientImpl(getBus(), ep);
+ Client client = new CamelCxfClientImpl(getBus(), ep);
+ this.getServiceFactory().sendEvent(FactoryBeanListener.Event.CLIENT_CREATED, client, ep);
+ return client;
}
@Override