diff options
Diffstat (limited to 'sca-java-2.x/tags/2.0-M5.1-RC1/modules/binding-ws-runtime-jaxws/src')
2 files changed, 0 insertions, 384 deletions
diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java deleted file mode 100644 index 65bcc0cfd9..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java +++ /dev/null @@ -1,204 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.tuscany.sca.binding.ws.jaxws; - -import java.net.MalformedURLException; -import java.net.URL; -import java.util.Iterator; - -import javax.wsdl.Binding; -import javax.wsdl.BindingOperation; -import javax.wsdl.extensions.soap.SOAPOperation; -import javax.wsdl.extensions.soap12.SOAP12Operation; -import javax.xml.namespace.QName; -import javax.xml.soap.Detail; -import javax.xml.soap.DetailEntry; -import javax.xml.soap.MessageFactory; -import javax.xml.soap.SOAPBody; -import javax.xml.soap.SOAPException; -import javax.xml.soap.SOAPFault; -import javax.xml.soap.SOAPMessage; -import javax.xml.soap.SOAPPart; -import javax.xml.ws.Dispatch; -import javax.xml.ws.Service; -import javax.xml.ws.WebServiceException; -import javax.xml.ws.WebServiceFeature; -import javax.xml.ws.soap.SOAPBinding; -import javax.xml.ws.soap.SOAPFaultException; - -import org.apache.tuscany.sca.binding.ws.WebServiceBinding; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.interfacedef.util.FaultException; -import org.apache.tuscany.sca.invocation.DataExchangeSemantics; -import org.apache.tuscany.sca.invocation.Invoker; -import org.apache.tuscany.sca.invocation.Message; -import org.w3c.dom.Node; - -/** - * Uses JAXWS Dispatch to invoke a remote web service - * - * @version $Rev$ $Date$ - */ -public class JAXWSBindingInvoker implements Invoker, DataExchangeSemantics { - private final static String SCA11_TUSCANY_NS = "http://tuscany.apache.org/xmlns/sca/1.1"; - - public static final String TUSCANY_PREFIX = "tuscany"; - public static final QName CALLBACK_ID_REFPARM_QN = new QName(SCA11_TUSCANY_NS, "CallbackID", TUSCANY_PREFIX); - public static final QName CONVERSATION_ID_REFPARM_QN = - new QName(SCA11_TUSCANY_NS, "ConversationID", TUSCANY_PREFIX); - - private Dispatch<SOAPMessage> dispatch; - private MessageFactory messageFactory; - private Operation operation; - private WebServiceBinding wsBinding; - - public JAXWSBindingInvoker(Operation operation, - WebServiceFeature[] features, - MessageFactory messageFactory, - WebServiceBinding wsBinding) { - this.messageFactory = messageFactory; - this.operation = operation; - this.wsBinding = wsBinding; - this.dispatch = createDispatch(wsBinding); - } - - private Dispatch<SOAPMessage> createDispatch(WebServiceBinding wsBinding) { - URL wsdlLocation = null; - try { - wsdlLocation = new URL(wsBinding.getWSDLDocument().getDocumentBaseURI()); - } catch (MalformedURLException e) { - try { - if (wsBinding.getWSDLDefinition().getLocation() != null){ - wsdlLocation = wsBinding.getWSDLDefinition().getLocation().toURL(); - } - } catch (MalformedURLException e1) { - // TODO Auto-generated catch block - e1.printStackTrace(); - } - } - - QName serviceName = null; - QName portName = null; - Service service = null; - - if (wsdlLocation != null){ - serviceName = wsBinding.getServiceName(); - portName = new QName(serviceName.getNamespaceURI(), wsBinding.getPortName()); - service = Service.create(wsdlLocation, serviceName); - } else { - serviceName = wsBinding.getService().getQName(); - portName = new QName(serviceName.getNamespaceURI(), wsBinding.getPort().getName()); - service = Service.create(serviceName); - service.addPort(portName, SOAPBinding.SOAP11HTTP_BINDING, wsBinding.getURI()); - } - - return service.createDispatch(portName, - SOAPMessage.class, - Service.Mode.MESSAGE); - } - - public Message invoke(Message msg) { - try { - SOAPMessage resp = invokeTarget(msg); - SOAPBody body = resp.getSOAPBody(); - if (body != null) { - SOAPFault fault = body.getFault(); - if (fault != null) { -// setFault(msg, fault); - } else { - // The 1st child element - msg.setBody(body.getChildElements().next()); - } - - } - } catch (SOAPFaultException e) { - setFault(msg, e); - } catch (WebServiceException e) { - msg.setFaultBody(e); - } catch (SOAPException e) { - msg.setFaultBody(e); - } catch (Throwable e) { - msg.setFaultBody(e); - } - - return msg; - } - - private void setFault(Message msg, SOAPFaultException e) { - SOAPFault fault = e.getFault(); - Detail detail = fault.getDetail(); - if (detail != null) { - for (Iterator i = detail.getDetailEntries(); i.hasNext();) { - DetailEntry entry = (DetailEntry)i.next(); - FaultException fe = new FaultException(e.getMessage(), entry.getFirstChild(), e); - fe.setFaultName(entry.getElementQName()); - msg.setFaultBody(fe); - } - } - } - - protected String getSOAPAction(String operationName) { - Binding binding = wsBinding.getBinding(); - if (binding != null) { - for (Object o : binding.getBindingOperations()) { - BindingOperation bop = (BindingOperation)o; - if (bop.getName().equalsIgnoreCase(operationName)) { - for (Object o2 : bop.getExtensibilityElements()) { - if (o2 instanceof SOAPOperation) { - return ((SOAPOperation)o2).getSoapActionURI(); - } else if (o2 instanceof SOAP12Operation) { - return ((SOAP12Operation)o2).getSoapActionURI(); - } - } - } - } - } - return null; - } - - protected SOAPMessage invokeTarget(Message msg) throws SOAPException { - SOAPMessage soapMessage = messageFactory.createMessage(); - SOAPPart soapPart = soapMessage.getSOAPPart(); - javax.xml.soap.SOAPEnvelope envelope = soapPart.getEnvelope(); - javax.xml.soap.SOAPBody body = envelope.getBody(); - Object[] args = (Object[])msg.getBody(); - // In the unit test the owner doc is null - // so explicitly adopt the node instead - //body.addDocument(((Node)args[0]).getOwnerDocument()); - Node msgNode = body.getOwnerDocument().importNode((Node)args[0], true); - body.appendChild(msgNode); - soapMessage.saveChanges(); - if (operation.isNonBlocking()) { - dispatch.invokeOneWay(soapMessage); - return null; - } - - // FIXME: We need to find out the soapAction - String action = getSOAPAction(operation.getName()); - if (action != null) { - dispatch.getRequestContext().put(Dispatch.SOAPACTION_URI_PROPERTY, action); - } - SOAPMessage response = dispatch.invoke(soapMessage); - return response; - } - - public boolean allowsPassByReference() { - return true; - } -} diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProvider.java b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProvider.java deleted file mode 100644 index 23e7d7d584..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/binding-ws-runtime-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingProvider.java +++ /dev/null @@ -1,180 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -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; -import javax.xml.soap.SOAPElement; -import javax.xml.soap.SOAPException; -import javax.xml.soap.SOAPFactory; -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; - -import org.apache.tuscany.sca.binding.ws.WebServiceBinding; -import org.apache.tuscany.sca.core.FactoryExtensionPoint; -import org.apache.tuscany.sca.databinding.DataBindingExtensionPoint; -import org.apache.tuscany.sca.host.http.ServletHost; -import org.apache.tuscany.sca.interfacedef.InterfaceContract; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.interfacedef.util.FaultException; -import org.apache.tuscany.sca.invocation.InvocationChain; -import org.apache.tuscany.sca.invocation.Message; -import org.apache.tuscany.sca.invocation.MessageFactory; -import org.apache.tuscany.sca.runtime.RuntimeEndpoint; -import org.oasisopen.sca.ServiceRuntimeException; -import org.w3c.dom.Element; -import org.w3c.dom.Node; - -@WebServiceProvider -@ServiceMode(Mode.MESSAGE) -public class JAXWSBindingProvider implements Provider<SOAPMessage> { - private MessageFactory messageFactory; - private RuntimeEndpoint endpoint; - 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, String defaultPort) { - - this.messageFactory = modelFactories.getFactory(MessageFactory.class); - - this.soapMessageFactory = modelFactories.getFactory(javax.xml.soap.MessageFactory.class); - this.soapFactory = modelFactories.getFactory(SOAPFactory.class); - - // soapMessageFactory = javax.xml.soap.MessageFactory.newInstance(); - // soapFactory = SOAPFactory.newInstance(); - - this.endpoint = endpoint; - this.wsBinding = (WebServiceBinding)endpoint.getBinding(); - - // A WSDL document should always be present in the binding - if (wsBinding.getWSDLDocument() == null) { - throw new ServiceRuntimeException("No WSDL document for " + endpoint.getURI()); - } - - // Set to use the DOM data binding - InterfaceContract contract = wsBinding.getBindingInterfaceContract(); - contract.getInterface().resetDataBinding(Node.class.getName()); - - // Can we safely assume there is only one port because you configure - // a binding in the following ways: - // 1/ default - one port generated = host domain : host port / structural path - // 2/ uri="absolute addr" - one port generated = host domain : uri port / uri path - // 3/ uri="relative addr" - one port generated = host domain : host port / structural path / relative path - // 4/ wsdl.binding - one port generated = host domain : host port / structural path - // 5/ wsdl.port - one port generated = host domain : port port / port path - // 6/ wsa:Address - one port generated = host domain : address port / address path - // 7/ 4 + 6 - as 6 - - // TODO the binding URI will currently have been calculated during build - // however we don't give the provider a chance to get in and effect the - // 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://")) { - 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:" + defaultPort + wsBinding.getURI(); - } - - wsBinding.setURI(serviceURI); - } - System.out.println("Binding.ws JAXWS provider - Service URI: " + wsBinding.getURI()); - } - - public void start() { - // TODO - do we need this? - } - - public void stop() { - // TODO - do we need this? - } - - public SOAPMessage invoke(SOAPMessage request) { - try { - // Assuming document-literal-wrapper style - Node root = request.getSOAPBody().getFirstChild(); - String operationName = root.getLocalName(); - Operation operation = null; - for (InvocationChain invocationChain : endpoint.getInvocationChains()) { - if (operationName.equals(invocationChain.getSourceOperation().getName())) { - operation = invocationChain.getSourceOperation(); - break; - } - } - if (operation == null) { - throw new SOAPException("Operation not found: " + operationName); - } - - Message requestMsg = messageFactory.createMessage(); - Object[] body = new Object[]{root}; - requestMsg.setBody(body); - requestMsg.setOperation(operation); - - Message responseMsg = endpoint.invoke(operation, requestMsg); - - SOAPMessage response = soapMessageFactory.createMessage(); - if (responseMsg.isFault()) { -// ServiceRuntimeException e = responseMsg.getBody(); -// throw e; - - FaultException fe = responseMsg.getBody(); - SOAPFault fault = response.getSOAPBody().addFault(new QName(response.getSOAPBody().getNamespaceURI(), "Server"), fe.getMessage()); - Detail d = fault.addDetail(); - DetailEntry de = d.addDetailEntry(fe.getFaultName()); - SOAPElement dece = de.addChildElement("message"); - if (fe.getMessage() != null) { - dece.addTextNode(fe.getMessage()); - } - - } else { - Element element = responseMsg.getBody(); - response.getSOAPBody().addChildElement(soapFactory.createElement(element)); - } - return response; - } catch (SOAPException e) { - throw new ServiceRuntimeException(e); - } - } -} |