diff options
author | slaws <slaws@13f79535-47bb-0310-9956-ffa450edef68> | 2010-04-20 18:02:09 +0000 |
---|---|---|
committer | slaws <slaws@13f79535-47bb-0310-9956-ffa450edef68> | 2010-04-20 18:02:09 +0000 |
commit | f6ff505e5bbfe699127f5c468562b4609b8c0f41 (patch) | |
tree | d7235ecbd5a64ca1e769861a67672c25ee9e5ee8 /sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache | |
parent | c8251b43e6fa344567aea01282d0ab093ab514d0 (diff) |
Make sure that the JAXWS runtime is stopped and put in temp fix for exception handling.
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@936017 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache')
-rw-r--r-- | sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProvider.java | 42 |
1 files changed, 35 insertions, 7 deletions
diff --git a/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProvider.java b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProvider.java index 79fd17507b..91e31acd4e 100644 --- a/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProvider.java +++ b/sca-java-2.x/trunk/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProvider.java @@ -18,6 +18,10 @@ */ package org.apache.tuscany.sca.binding.ws.jaxws; +import java.util.List; + +import javax.annotation.Resource; +import javax.wsdl.extensions.soap.SOAPAddress; import javax.xml.namespace.QName; import javax.xml.soap.Detail; import javax.xml.soap.DetailEntry; @@ -28,6 +32,7 @@ import javax.xml.soap.SOAPFault; import javax.xml.soap.SOAPMessage; import javax.xml.ws.Provider; import javax.xml.ws.ServiceMode; +import javax.xml.ws.WebServiceContext; import javax.xml.ws.WebServiceProvider; import javax.xml.ws.Service.Mode; @@ -54,11 +59,14 @@ public class JAXWSBindingProvider implements Provider<SOAPMessage> { private WebServiceBinding wsBinding; private javax.xml.soap.MessageFactory soapMessageFactory; private SOAPFactory soapFactory; + + @Resource + private WebServiceContext context; public JAXWSBindingProvider(RuntimeEndpoint endpoint, - ServletHost servletHost, - FactoryExtensionPoint modelFactories, - DataBindingExtensionPoint dataBindings) { + ServletHost servletHost, + FactoryExtensionPoint modelFactories, + DataBindingExtensionPoint dataBindings) { this.messageFactory = modelFactories.getFactory(MessageFactory.class); @@ -95,7 +103,22 @@ public class JAXWSBindingProvider implements Provider<SOAPMessage> { // calculation (see above comment). For now just fake the addition of binding // specific processing by adding a root if it's not already present if (!wsBinding.getURI().startsWith("http://")) { - wsBinding.setURI("http://localhost:8085" + wsBinding.getURI()); + String serviceURI = null; + + // look in the port for the location URL + List wsdlPortExtensions = wsBinding.getPort().getExtensibilityElements(); + for (final Object extension : wsdlPortExtensions) { + if (extension instanceof SOAPAddress) { + serviceURI = ((SOAPAddress) extension).getLocationURI(); + } + } + + if (serviceURI == null || + !serviceURI.startsWith("http://")){ + serviceURI = "http://localhost:8080" + wsBinding.getURI(); + } + + wsBinding.setURI(serviceURI); } System.out.println("Binding.ws JAXWS provider - Service URI: " + wsBinding.getURI()); } @@ -108,7 +131,7 @@ public class JAXWSBindingProvider implements Provider<SOAPMessage> { // TODO - do we need this? } - public SOAPMessage invoke(SOAPMessage request) { + public SOAPMessage invoke(SOAPMessage request) { try { // Assuming document-literal-wrapper style Node root = request.getSOAPBody().getFirstChild(); @@ -128,10 +151,14 @@ public class JAXWSBindingProvider implements Provider<SOAPMessage> { Object[] body = new Object[]{root}; requestMsg.setBody(body); requestMsg.setOperation(operation); + Message responseMsg = endpoint.invoke(operation, requestMsg); + SOAPMessage response = soapMessageFactory.createMessage(); if (responseMsg.isFault()) { - FaultException fe = responseMsg.getBody(); + ServiceRuntimeException e = responseMsg.getBody(); + throw e; +/* SOAPFault fault = response.getSOAPBody().addFault(new QName(response.getSOAPBody().getNamespaceURI(), "Server"), "unknown"); Detail d = fault.addDetail(); DetailEntry de = d.addDetailEntry(fe.getFaultName()); @@ -139,6 +166,7 @@ public class JAXWSBindingProvider implements Provider<SOAPMessage> { if (fe.getMessage() != null) { dece.addTextNode(fe.getMessage()); } +*/ } else { Element element = responseMsg.getBody(); response.getSOAPBody().addChildElement(soapFactory.createElement(element)); @@ -146,6 +174,6 @@ public class JAXWSBindingProvider implements Provider<SOAPMessage> { return response; } catch (SOAPException e) { throw new ServiceRuntimeException(e); - } + } } } |