summaryrefslogtreecommitdiffstats
path: root/java/sca-contrib/modules/binding-ws-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/sca-contrib/modules/binding-ws-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java')
-rw-r--r--java/sca-contrib/modules/binding-ws-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java181
1 files changed, 0 insertions, 181 deletions
diff --git a/java/sca-contrib/modules/binding-ws-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java b/java/sca-contrib/modules/binding-ws-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java
deleted file mode 100644
index ecb3b4f87b..0000000000
--- a/java/sca-contrib/modules/binding-ws-jaxws/src/main/java/org/apache/tuscany/sca/binding/ws/jaxws/JAXWSBindingInvoker.java
+++ /dev/null
@@ -1,181 +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.SOAPFaultException;
-
-import org.apache.tuscany.sca.binding.ws.WebServiceBinding;
-import org.apache.tuscany.sca.interfacedef.Operation;
-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;
-
-/**
- * Axis2BindingInvoker uses an Axis2 OperationClient 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) {
- // FIXME: What should we do if the WSDL is generated in memory?
- URL wsdlLocation = null;
- try {
- wsdlLocation = new URL(wsBinding.getWSDLDocument().getDocumentBaseURI());
- } catch (MalformedURLException e) {
- try {
- wsdlLocation = wsBinding.getWSDLDefinition().getLocation().toURL();
- } catch (MalformedURLException e1) {
- // TODO Auto-generated catch block
- e1.printStackTrace();
- }
- }
- Service service = Service.create(wsdlLocation, wsBinding.getServiceName());
- return service.createDispatch(new QName(wsBinding.getServiceName().getNamespaceURI(), wsBinding.getPortName()),
- 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) {
- e.printStackTrace();
- setFault(msg, e.getFault());
- } 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, SOAPFault fault) {
- Detail detail = fault.getDetail();
- if (detail == null) {
- return;
- }
- for (Iterator i = detail.getDetailEntries(); i.hasNext();) {
- DetailEntry entry = (DetailEntry)i.next();
- msg.setFaultBody(entry);
- }
- }
-
- 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();
- body.addDocument(((Node)args[0]).getOwnerDocument());
- 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;
- }
-}