Author: slaws
Date: Wed Feb 3 18:45:52 2010
New Revision: 906169
URL: http://svn.apache.org/viewvc?rev=906169&view=rev
Log:
back up some experimental code
Modified:
tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2EngineIntegration.java
tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2ServiceClient.java
Modified:
tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2EngineIntegration.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2EngineIntegration.java?rev=906169&r1=906168&r2=906169&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2EngineIntegration.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2EngineIntegration.java
Wed Feb 3 18:45:52 2010
@@ -19,6 +19,7 @@
package org.apache.tuscany.sca.binding.ws.axis2;
+import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
@@ -48,10 +49,10 @@
import org.apache.axiom.om.OMFactory;
import org.apache.axis2.AxisFault;
import org.apache.axis2.Constants;
-import org.apache.axis2.Constants.Configuration;
import org.apache.axis2.addressing.AddressingConstants;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.deployment.URLBasedAxisConfigurator;
import org.apache.axis2.deployment.util.Utils;
import org.apache.axis2.description.AxisEndpoint;
import org.apache.axis2.description.AxisOperation;
@@ -66,40 +67,42 @@
import org.apache.axis2.engine.MessageReceiver;
import org.apache.axis2.transport.jms.JMSListener;
import org.apache.axis2.transport.jms.JMSSender;
+import org.apache.axis2.transport.local.LocalResponder;
import org.apache.tuscany.sca.assembly.AbstractContract;
import org.apache.tuscany.sca.assembly.AssemblyFactory;
import org.apache.tuscany.sca.binding.ws.WebServiceBinding;
import
org.apache.tuscany.sca.binding.ws.axis2.Axis2ServiceClient.URIResolverImpl;
+import
org.apache.tuscany.sca.binding.ws.axis2.policy.mtom.Axis2MTOMPolicyProvider;
import org.apache.tuscany.sca.core.FactoryExtensionPoint;
import org.apache.tuscany.sca.core.assembly.RuntimeAssemblyFactory;
+import org.apache.tuscany.sca.extensibility.ClassLoaderContext;
import org.apache.tuscany.sca.host.http.ServletHost;
import org.apache.tuscany.sca.interfacedef.Interface;
import org.apache.tuscany.sca.interfacedef.Operation;
import org.apache.tuscany.sca.interfacedef.java.JavaInterface;
import org.apache.tuscany.sca.interfacedef.wsdl.WSDLDefinition;
import org.apache.tuscany.sca.invocation.MessageFactory;
-import org.apache.tuscany.sca.policy.PolicySet;
+import org.apache.tuscany.sca.policy.util.PolicyHelper;
+import org.apache.tuscany.sca.provider.PolicyProvider;
import org.apache.tuscany.sca.runtime.RuntimeComponent;
import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
import org.apache.tuscany.sca.xsd.XSDefinition;
import org.apache.ws.commons.schema.XmlSchema;
import org.apache.ws.commons.schema.XmlSchemaExternal;
+import org.apache.xerces.jaxp.DocumentBuilderFactoryImpl;
+import org.oasisopen.sca.ServiceRuntimeException;
import org.w3c.dom.Element;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
+import com.ctc.wstx.stax.WstxInputFactory;
+
+
public class Axis2EngineIntegration {
private static final Logger logger =
Logger.getLogger(Axis2EngineIntegration.class.getName());
- private ConfigurationContext configContext;
-
- //============================
-
- public static final String IMPORT_TAG = "import";
- public static final String INCLUDE_TAG = "include";
-
private RuntimeEndpoint endpoint;
private RuntimeComponent component;
private AbstractContract contract;
@@ -109,9 +112,40 @@
private FactoryExtensionPoint modelFactories;
private RuntimeAssemblyFactory assemblyFactory;
+ private ConfigurationContext configContext;
+
+ // a map of all endpoint URIs to WSDL ports for which service will be
started
+ //
+ private Map<String, Port> urlMap = new HashMap<String, Port>();
+
+ // default provided intents
+ public static final String SCA_11_NS =
org.apache.tuscany.sca.assembly.xml.Constants.SCA11_NS;
+ public static final String SCA_11_TUSCANY_NS =
org.apache.tuscany.sca.assembly.xml.Constants.SCA11_TUSCANY_NS;
+
+ // TODO - move these constants to assembly
+ public static final QName AUTHENTICATION_INTENT = new QName(SCA_11_NS,
"authentication");
+ public static final QName CONFIDENTIALITY_INTENT = new QName(SCA_11_NS,
"confidentiality");
+ public static final QName INTEGRITY_INTENT = new QName(SCA_11_NS,
"integrity");
+ public static final QName MTOM_INTENT = new QName(SCA_11_TUSCANY_NS,
"MTOM");
+ public static final QName SOAP_INTENT = new QName(SCA_11_NS, "SOAP");
+ public static final QName SOAP11_INTENT = new QName(SCA_11_NS, "SOAP.1_1");
+ public static final QName SOAP12_INTENT = new QName(SCA_11_NS, "SOAP.1_2");
+
+ private boolean isSOAP12Required = false;
+ private boolean isRampartRequired = false;
+ private boolean isMTOMRequired = false;
+ private boolean isJMSRequired = false;
+
+ // JMS transport support
private JMSSender jmsSender;
private JMSListener jmsListener;
- private Map<String, Port> urlMap = new HashMap<String, Port>();
+
+ //=========================================================
+ // most of the following is related to rewriting WSDL imports
+ // I'd like to move this but don't know where to yet.
+
+ public static final String IMPORT_TAG = "import";
+ public static final String INCLUDE_TAG = "include";
public static final QName QNAME_WSA_ADDRESS =
@@ -121,8 +155,6 @@
public static final QName QNAME_WSA_REFERENCE_PARAMETERS =
new QName(AddressingConstants.Final.WSA_NAMESPACE,
AddressingConstants.EPR_REFERENCE_PARAMETERS);
- private static final QName TRANSPORT_JMS_QUALIFIED_INTENT =
- new QName("http://docs.oasis-open.org/ns/opencsa/sca/200912";,
"transport.jms");
private static final String DEFAULT_QUEUE_CONNECTION_FACTORY =
"TuscanyQueueConnectionFactory";
//Schema element names
@@ -139,10 +171,13 @@
public static final QName Q_ELEM_XSD_2001 = new QName(NS_URI_XSD_2001,
ELEM_SCHEMA);
public static final List<QName> XSD_QNAME_LIST =
Arrays.asList(new QName[] {Q_ELEM_XSD_1999, Q_ELEM_XSD_2000,
Q_ELEM_XSD_2001});
+
+ //=========================================================
/**
* Construct the service provider. This creates the base configuration for
- * Axis2 but with no services deployed yet.
+ * Axis2 but with no services deployed yet. Services will be deployed when
+ * this service binding provider is started
*
* @param endpoint
* @param component
@@ -168,136 +203,108 @@
this.modelFactories = modelFactories;
this.assemblyFactory =
(RuntimeAssemblyFactory)modelFactories.getFactory(AssemblyFactory.class);
- final boolean isRampartRequired =
AxisPolicyHelper.isRampartRequired(wsBinding);
-
- // get the axis configuration context from the Tuscany axis2.xml file
- // TODO - java security
- ClassLoader wsBindingCL = getClass().getClassLoader();
-
// TODO - taken the Tuscany configurator out for a while
// but may need to re-introduce a simplified version if we feel
// that it's important to not deploy rampart when it's not
required
+
+ // get the axis configuration context from the Tuscany axis2.xml file
+ // Allow privileged access to read properties. Requires
PropertyPermission read in
+ // security policy.
try {
- URL axis2xmlURL =
wsBindingCL.getResource("org/apache/tuscany/sca/binding/ws/axis2/engine/conf/tuscany-axis2.xml");
- if (axis2xmlURL != null){
- URL repositoryURL = new
URL(axis2xmlURL.toExternalForm().replaceFirst("conf/tuscany-axis2.xml",
"repository"));
- configContext =
ConfigurationContextFactory.createConfigurationContextFromURIs(axis2xmlURL,
repositoryURL);
- } else {
- // throw an exception
- }
- } catch (Exception ex) {
- ex.printStackTrace();
- }
+ configContext = AccessController.doPrivileged(new
PrivilegedExceptionAction<ConfigurationContext>() {
+ public ConfigurationContext run() throws AxisFault,
MalformedURLException {
+ // collect together the classloaders that Axis2 requireds
in order to load
+ // pluggable items such as the Tuscany MessageReceivers
and the xerces
+ // document builder.
+ ClassLoader wsBindingCL = getClass().getClassLoader();
+ ClassLoader axis2CL =
URLBasedAxisConfigurator.class.getClassLoader();
+ ClassLoader xercesCL =
DocumentBuilderFactoryImpl.class.getClassLoader();
+ ClassLoader wstxCL =
WstxInputFactory.class.getClassLoader();
+ ClassLoader localtransportCL =
LocalResponder.class.getClassLoader();
+ ClassLoader oldTCCL =
ClassLoaderContext.setContextClassLoader(wsBindingCL, axis2CL, xercesCL,
wstxCL, localtransportCL);
+
+ try {
+ URL axis2xmlURL =
wsBindingCL.getResource("org/apache/tuscany/sca/binding/ws/axis2/engine/conf/tuscany-axis2.xml");
+ if (axis2xmlURL != null){
+ URL repositoryURL = new
URL(axis2xmlURL.toExternalForm().replaceFirst("conf/tuscany-axis2.xml",
"repository/"));
+ return
ConfigurationContextFactory.createConfigurationContextFromURIs(axis2xmlURL,
repositoryURL);
+ } else {
+ return null;
+ }
+ } finally {
+ if (oldTCCL != null) {
+
Thread.currentThread().setContextClassLoader(oldTCCL);
+ }
+ }
+ }
+ });
+ } catch (PrivilegedActionException e) {
+ throw new ServiceRuntimeException(e.getException());
+ }
// set the root context for this instance of Axis
configContext.setContextRoot(servletHost.getContextPath());
- // TODO - Cycle through all policy providers asking if there is
configuration
- // todo. Should this be in the
- // MTOM
- // JMS
- // Security (turn rampart on)
- // Enable MTOM if the policy intent is specified.
- if (AxisPolicyHelper.isIntentRequired(wsBinding,
AxisPolicyHelper.MTOM_INTENT)) {
-
configContext.getAxisConfiguration().getParameter(Configuration.ENABLE_MTOM).setLocked(false);
-
configContext.getAxisConfiguration().getParameter(Configuration.ENABLE_MTOM).setValue("true");
- }
+ // Determine the configuration from the mayProvides intents
+
+ isSOAP12Required = PolicyHelper.isIntentRequired(wsBinding,
SOAP12_INTENT);
+ // this is not correct as there may be other, custom, policies that
+ // require rampart. For example this is not going to pick up the case
+ // of external policy attachment
+ isRampartRequired = PolicyHelper.isIntentRequired(wsBinding,
AUTHENTICATION_INTENT) ||
+ PolicyHelper.isIntentRequired(wsBinding,
CONFIDENTIALITY_INTENT) ||
+ PolicyHelper.isIntentRequired(wsBinding,
INTEGRITY_INTENT);
+
// Update port addresses with runtime information, and create a
// map from endpoint URIs to WSDL ports that eliminates duplicate
// ports for the same endpoint.
+ // TODO - when do we think we are dealing with more than one port on
the service side?
+ // is this an OSOA thing?
for (Object port : wsBinding.getService().getPorts().values()) {
- String portAddress = getPortAddress((Port)port);
- String endpointURI = computeEndpointURI(portAddress, servletHost);
+ String endpointURI = getPortAddress((Port)port);
+ if (!endpointURI.startsWith("jms:")) {
+ endpointURI =
servletHost.getURLMapping(endpointURI).toString();
+ } else {
+ isJMSRequired = true;
+ }
setPortAddress((Port)port, endpointURI);
urlMap.put(endpointURI, (Port)port);
- }
+ }
- }
-
-
- static String getPortAddress(Port port) {
- Object ext = port.getExtensibilityElements().get(0);
- if (ext instanceof SOAPAddress) {
- return ((SOAPAddress)ext).getLocationURI();
- }
- if (ext instanceof SOAP12Address) {
- return ((SOAP12Address)ext).getLocationURI();
- }
- return null;
- }
-
- static void setPortAddress(Port port, String locationURI) {
- Object ext = port.getExtensibilityElements().get(0);
- if (ext instanceof SOAPAddress) {
- ((SOAPAddress)ext).setLocationURI(locationURI);
- }
- if (ext instanceof SOAP12Address) {
- ((SOAP12Address)ext).setLocationURI(locationURI);
- }
- }
-
- private String computeEndpointURI(String uri, ServletHost servletHost) {
-
- if (uri == null) {
- return null;
+ isMTOMRequired = PolicyHelper.isIntentRequired(wsBinding, MTOM_INTENT);
+
+
+ // Apply the configuration from any other policies
+
+ for (PolicyProvider pp : endpoint.getPolicyProviders()) {
+ // we probably want to pass the whole provider in here
+ // so that the policy providers can get at the rampart
configuration
+ pp.configureBinding(configContext);
}
-
- // pull out the binding intents to see what sort of transport is
required
- PolicySet transportJmsPolicySet =
AxisPolicyHelper.getPolicySet(wsBinding, TRANSPORT_JMS_QUALIFIED_INTENT);
- if (transportJmsPolicySet != null) {
- if (!uri.startsWith("jms:/")) {
- uri = "jms:" + uri;
- }
-
- // construct the rest of the URI based on the policy. All the
details are put
- // into the URI here rather than being place directly into the
Axis configuration
- // as the Axis JMS sender relies on parsing the target URI
-/*
- Axis2ConfigParamPolicy axis2ConfigParamPolicy = null;
- for (Object policy : transportJmsPolicySet.getPolicies()) {
- if (policy instanceof Axis2ConfigParamPolicy) {
- axis2ConfigParamPolicy = (Axis2ConfigParamPolicy)policy;
- Iterator paramIterator =
-
axis2ConfigParamPolicy.getParamElements().get(DEFAULT_QUEUE_CONNECTION_FACTORY)
- .getChildElements();
-
- if (paramIterator.hasNext()) {
- StringBuffer uriParams = new StringBuffer("?");
-
- while (paramIterator.hasNext()) {
- OMElement parameter =
(OMElement)paramIterator.next();
- uriParams.append(parameter.getAttributeValue(new
QName("", "name")));
- uriParams.append("=");
- uriParams.append(parameter.getText());
-
- if (paramIterator.hasNext()) {
- uriParams.append("&");
- }
- }
-
- uri = uri + uriParams;
- }
- }
- }
-*/
- } else {
- if (!uri.startsWith("jms:")) {
- uri = servletHost.getURLMapping(uri).toString();
- }
+
+ // Apply the configuration from the mayProvides intents
+
+ if (isRampartRequired){
+ // TODO - do we need to go back to configurator?
}
-
- return uri;
+
+ if (isJMSRequired){
+ // TODO - do we need to o go back to configurator?
+ }
+
+ if (isMTOMRequired) {
+ new
Axis2MTOMPolicyProvider(endpoint).configureBinding(configContext);
+ }
+
}
-
+
/**
- * Add the Tuscany services that this binding instance represents to the
+ * Add the Tuscany services, that this binding instance represents, to the
* Axis runtime.
*/
public void start() {
-
try {
- //createPolicyHandlers();
for (Map.Entry<String, Port> entry : urlMap.entrySet()) {
AxisService axisService = createAxisService(entry.getKey(),
entry.getValue());
configContext.getAxisConfiguration().addService(axisService);
@@ -305,13 +312,13 @@
Axis2ServiceServlet servlet = null;
for (String endpointURL : urlMap.keySet()) {
- if (endpointURL.startsWith("http://";) ||
endpointURL.startsWith("https://";)
- || endpointURL.startsWith("/")) {
+ if (endpointURL.startsWith("http://";) ||
+ endpointURL.startsWith("https://";) ||
+ endpointURL.startsWith("/")) {
if (servlet == null) {
servlet = new Axis2ServiceServlet();
servlet.init(configContext);
}
- //[nash] configContext.setContextRoot(endpointURL);
servletHost.addServletMapping(endpointURL, servlet);
} else if (endpointURL.startsWith("jms")) {
logger.log(Level.INFO, "Axis2 JMS URL=" + endpointURL);
@@ -422,7 +429,7 @@
}
/**
- * Create an AxisService from the interface class from the SCA service
interface
+ * Create an AxisService from the Java interface class of the SCA service
interface
*/
protected AxisService createJavaAxisService(String endpointURL) throws
AxisFault {
@@ -456,6 +463,7 @@
final WSDLToAxisServiceBuilder builder = new
WSDL11ToAxisServiceBuilder(def, serviceQName, port.getName());
builder.setServerSide(true);
// [rfeng] Add a custom resolver to work around WSCOMMONS-228
+ // TODO - 228 is resolved, is this still required
builder.setCustomResolver(new URIResolverImpl(def));
builder.setBaseUri(def.getDocumentBaseURI());
// [rfeng]
@@ -481,6 +489,9 @@
axisService.setName(name);
axisService.setEndpointURL(endpointURL);
axisService.setDocumentation("Tuscany configured AxisService for
service: " + endpointURL);
+
+ // TODO - again, do we ever have more than one endpoint
+ // on the service side?
for (Iterator i = axisService.getEndpoints().values().iterator();
i.hasNext();) {
AxisEndpoint ae = (AxisEndpoint)i.next();
if (endpointURL.startsWith("jms")) {
@@ -653,4 +664,28 @@
}
return null;
}
+
+
+ // Utility operations. Should these be available to the client also?
+
+ static String getPortAddress(Port port) {
+ Object ext = port.getExtensibilityElements().get(0);
+ if (ext instanceof SOAPAddress) {
+ return ((SOAPAddress)ext).getLocationURI();
+ }
+ if (ext instanceof SOAP12Address) {
+ return ((SOAP12Address)ext).getLocationURI();
+ }
+ return null;
+ }
+
+ static void setPortAddress(Port port, String locationURI) {
+ Object ext = port.getExtensibilityElements().get(0);
+ if (ext instanceof SOAPAddress) {
+ ((SOAPAddress)ext).setLocationURI(locationURI);
+ }
+ if (ext instanceof SOAP12Address) {
+ ((SOAP12Address)ext).setLocationURI(locationURI);
+ }
+ }
}
Modified:
tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2ServiceClient.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2ServiceClient.java?rev=906169&r1=906168&r2=906169&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2ServiceClient.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/binding-ws-runtime-axis2/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/Axis2ServiceClient.java
Wed Feb 3 18:45:52 2010
@@ -22,6 +22,7 @@
import static
org.apache.tuscany.sca.binding.ws.axis2.AxisPolicyHelper.isIntentRequired;
import java.io.IOException;
+import java.net.MalformedURLException;
import java.net.URL;
import java.security.AccessController;
import java.security.PrivilegedAction;
@@ -29,7 +30,6 @@
import java.security.PrivilegedExceptionAction;
import java.util.Collection;
import java.util.List;
-import java.util.Map;
import javax.wsdl.Binding;
import javax.wsdl.BindingOperation;
@@ -57,12 +57,13 @@
import org.apache.axis2.client.ServiceClient;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.deployment.URLBasedAxisConfigurator;
import org.apache.axis2.description.AxisEndpoint;
import org.apache.axis2.description.AxisService;
-import org.apache.axis2.description.Parameter;
import org.apache.axis2.description.WSDL11ToAxisServiceBuilder;
import org.apache.axis2.description.WSDL2Constants;
import org.apache.axis2.transport.http.HTTPConstants;
+import org.apache.axis2.transport.local.LocalResponder;
import org.apache.axis2.util.threadpool.ThreadPool;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager;
@@ -70,6 +71,7 @@
import org.apache.tuscany.sca.assembly.AbstractContract;
import org.apache.tuscany.sca.binding.ws.WebServiceBinding;
import org.apache.tuscany.sca.common.xml.XMLDocumentHelper;
+import org.apache.tuscany.sca.extensibility.ClassLoaderContext;
import org.apache.tuscany.sca.interfacedef.Operation;
import org.apache.tuscany.sca.invocation.Invoker;
import org.apache.tuscany.sca.invocation.MessageFactory;
@@ -77,6 +79,10 @@
import org.apache.tuscany.sca.policy.PolicySubject;
import org.apache.tuscany.sca.runtime.RuntimeComponent;
import org.apache.ws.commons.schema.resolver.URIResolver;
+import org.apache.xerces.jaxp.DocumentBuilderFactoryImpl;
+import org.oasisopen.sca.ServiceRuntimeException;
+
+import com.ctc.wstx.stax.WstxInputFactory;
public class Axis2ServiceClient {
@@ -132,23 +138,39 @@
ConfigurationContext configContext = null;
// get the axis configuration context from the Tuscany axis2.xml
file
- // TODO - java security
- ClassLoader wsBindingCL = getClass().getClassLoader();
-
- // TODO - taken the Tuscany configurator out for a while
- // but may need to re-introduce a simplified version if we
feel
- // that it's important to not deploy rampart when it's not
required
+ // Allow privileged access to read properties. Requires
PropertyPermission read in
+ // security policy.
try {
- URL axis2xmlURL =
wsBindingCL.getResource("org/apache/tuscany/sca/binding/ws/axis2/engine/conf/tuscany-axis2.xml");
- if (axis2xmlURL != null){
- URL repositoryURL = new
URL(axis2xmlURL.toExternalForm().replaceFirst("conf/tuscany-axis2.xml",
"repository"));
- configContext =
ConfigurationContextFactory.createConfigurationContextFromURIs(axis2xmlURL,
repositoryURL);
- } else {
- // throw an exception
- }
- } catch (Exception ex) {
- ex.printStackTrace();
- }
+ configContext = AccessController.doPrivileged(new
PrivilegedExceptionAction<ConfigurationContext>() {
+ public ConfigurationContext run() throws AxisFault,
MalformedURLException {
+ // collect together the classloaders that Axis2
requireds in order to load
+ // pluggable items such as the Tuscany
MessageReceivers and the xerces
+ // document builder.
+ ClassLoader wsBindingCL = getClass().getClassLoader();
+ ClassLoader axis2CL =
URLBasedAxisConfigurator.class.getClassLoader();
+ ClassLoader xercesCL =
DocumentBuilderFactoryImpl.class.getClassLoader();
+ ClassLoader wstxCL =
WstxInputFactory.class.getClassLoader();
+ ClassLoader localtransportCL =
LocalResponder.class.getClassLoader();
+ ClassLoader oldTCCL =
ClassLoaderContext.setContextClassLoader(wsBindingCL, axis2CL, xercesCL,
wstxCL, localtransportCL);
+
+ try {
+ URL axis2xmlURL =
wsBindingCL.getResource("org/apache/tuscany/sca/binding/ws/axis2/engine/conf/tuscany-axis2.xml");
+ if (axis2xmlURL != null){
+ URL repositoryURL = new
URL(axis2xmlURL.toExternalForm().replaceFirst("conf/tuscany-axis2.xml",
"repository/"));
+ return
ConfigurationContextFactory.createConfigurationContextFromURIs(axis2xmlURL,
repositoryURL);
+ } else {
+ return null;
+ }
+ } finally {
+ if (oldTCCL != null) {
+
Thread.currentThread().setContextClassLoader(oldTCCL);
+ }
+ }
+ }
+ });
+ } catch (PrivilegedActionException e) {
+ throw new ServiceRuntimeException(e.getException());
+ }
createPolicyHandlers();
