From f8f1555ae9cc86f9af4d551cabb3ea7325a9da1c Mon Sep 17 00:00:00 2001 From: rfeng Date: Wed, 1 Jul 2009 23:54:45 +0000 Subject: Add the fault explanation to the error message git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@790423 13f79535-47bb-0310-9956-ffa450edef68 --- .../bpel/ode/provider/BPELInvoker.java | 75 +++++++++++----------- 1 file changed, 38 insertions(+), 37 deletions(-) (limited to 'java/sca/modules/implementation-bpel-runtime/src') diff --git a/java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELInvoker.java b/java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELInvoker.java index 0b22929ae3..982f567824 100644 --- a/java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELInvoker.java +++ b/java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELInvoker.java @@ -6,15 +6,15 @@ * 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. + * under the License. */ package org.apache.tuscany.sca.implementation.bpel.ode.provider; @@ -33,7 +33,6 @@ import org.apache.ode.bpel.iapi.MyRoleMessageExchange; import org.apache.ode.bpel.iapi.MessageExchange.Status; import org.apache.ode.utils.DOMUtils; import org.apache.ode.utils.GUID; -import org.apache.ode.utils.Properties; import org.apache.tuscany.sca.implementation.bpel.ode.EmbeddedODEServer; import org.apache.tuscany.sca.interfacedef.Interface; import org.apache.tuscany.sca.interfacedef.Operation; @@ -47,27 +46,27 @@ import org.w3c.dom.Element; /** * Implements a target invoker for BPEL component implementations. - * + * * The target invoker is responsible for dispatching invocations to the particular * component implementation logic. In this example we are simply delegating the * CRUD operation invocations to the corresponding methods on our fake * resource manager. - * + * * @version $Rev$ $Date$ */ public class BPELInvoker implements Invoker { protected final Log __log = LogFactory.getLog(getClass()); - + private EmbeddedODEServer odeServer; private TransactionManager txMgr; - + private RuntimeComponentService service; private Operation operation; private QName bpelServiceName; private String bpelOperationName; private Part bpelOperationInputPart; private Part bpelOperationOutputPart; - + public BPELInvoker(RuntimeComponent component, RuntimeComponentService service, Operation operation, EmbeddedODEServer odeServer, TransactionManager txMgr) { this.service = service; this.operation = operation; @@ -78,28 +77,28 @@ public class BPELInvoker implements Invoker { initializeInvocation(); } - + private void initializeInvocation() { - + __log.debug("Initializing BPELInvoker"); Interface interfaze = operation.getInterface(); if(interfaze instanceof WSDLInterface){ WSDLInterface wsdlInterface = null; wsdlInterface = (WSDLInterface) interfaze; - + // The following commented out code is bogus and is replaced by what follows - Mike Edwards - // Service serviceDefinition = (Service) wsdlInterface.getWsdlDefinition().getDefinition().getAllServices().values().iterator().next(); + // Service serviceDefinition = (Service) wsdlInterface.getWsdlDefinition().getDefinition().getAllServices().values().iterator().next(); // bpelServiceName = serviceDefinition.getQName(); // // Fetch the service name from the service object bpelServiceName = new QName( "http://tuscany.apache.org", service.getName() ); - + bpelOperationInputPart = (Part) wsdlInterface.getPortType().getOperation(bpelOperationName,null,null).getInput().getMessage().getParts().values().iterator().next(); bpelOperationOutputPart = (Part) wsdlInterface.getPortType().getOperation(bpelOperationName,null,null).getOutput().getMessage().getParts().values().iterator().next(); } } - + public Message invoke(Message msg) { try { Object[] args = msg.getBody(); @@ -113,14 +112,14 @@ public class BPELInvoker implements Invoker { public Object doTheWork(Object[] args) throws InvocationTargetException { Element response = null; - + if(! (operation.getInterface() instanceof WSDLInterface)) { throw new InvocationTargetException(null,"Unsupported service contract"); } - + org.apache.ode.bpel.iapi.MyRoleMessageExchange mex = null; Future onhold = null; - + //Process the BPEL process invocation try { txMgr.begin(); @@ -129,7 +128,7 @@ public class BPELInvoker implements Invoker { bpelOperationName); mex.setProperty("isTwoWay", "true"); onhold = mex.invoke(createInvocationMessage(mex, args)); - + txMgr.commit(); } catch (Exception e) { try { @@ -138,7 +137,7 @@ public class BPELInvoker implements Invoker { } throw new InvocationTargetException(e, "Error invoking BPEL process : " + e.getMessage()); - } + } // Waiting until the reply is ready in case the engine needs to continue in a different thread @@ -158,19 +157,21 @@ public class BPELInvoker implements Invoker { mex = (MyRoleMessageExchange)odeServer.getBpelServer().getEngine().getMessageExchange(mex.getMessageExchangeId()); Status status = mex.getStatus(); - + if (__log.isDebugEnabled()) { Element invocationResponse = mex.getResponse().getMessage(); __log.debug(">>>Invocation status:" + status.name()); __log.debug(">>>Response:\n" + DOMUtils.domToString(invocationResponse)); __log.debug(">>>Response:\n" + DOMUtils.domToString(invocationResponse)); } // end if - + switch (status) { case FAULT: if (__log.isDebugEnabled()) __log.debug("Fault response message: " + mex.getFault()); - throw new ODEInvocationException("FAULT received from BPEL process : " + mex.getFault()); + throw new ODEInvocationException("FAULT received from BPEL process : " + mex.getFault() + + " " + + mex.getFaultExplanation()); case ASYNC: case RESPONSE: //process the method invocation result @@ -185,7 +186,7 @@ public class BPELInvoker implements Invoker { default: throw new ODEInvocationException("FAILURE received from BPEL process : " + mex.getFault()); } // end switch - + txMgr.commit(); // end of transaction two } catch (Exception e) { @@ -196,14 +197,14 @@ public class BPELInvoker implements Invoker { } throw new InvocationTargetException(e, "Error retrieving BPEL process invocation status : " + e.getMessage()); } - - + + return response; } /** * Create BPEL Invocation message - * + * * BPEL invocation message like : * * @@ -215,22 +216,22 @@ public class BPELInvoker implements Invoker { */ private org.apache.ode.bpel.iapi.Message createInvocationMessage(org.apache.ode.bpel.iapi.MyRoleMessageExchange mex, Object[] args) { Document dom = DOMUtils.newDocument(); - + Element contentMessage = dom.createElement("message"); Element contentPart = dom.createElement(bpelOperationInputPart.getName()); Element payload = null; - + //TUSCANY-2321 - Properly handling Document or Element types if(args[0] instanceof Document) { payload = (Element) ((Document) args[0]).getFirstChild(); } else { payload = (Element) args[0]; } - + contentPart.appendChild(dom.importNode(payload, true)); contentMessage.appendChild(contentPart); dom.appendChild(contentMessage); - + if (__log.isDebugEnabled()) { __log.debug("Creating invocation message:"); __log.debug(">> args.....: " + DOMUtils.domToString(payload)); @@ -239,25 +240,25 @@ public class BPELInvoker implements Invoker { org.apache.ode.bpel.iapi.Message request = mex.createMessage(new QName("", "")); request.setMessage(dom.getDocumentElement()); - + return request; } - + /** * Process BPEL response - * + * * * * World * - * - * + * + * * @param response * @return */ private Element processResponse(Element response) { return (Element) DOMUtils.findChildByName(response, new QName("",bpelOperationOutputPart.getName())).getFirstChild(); - + // MJE, 12/06/2009 - changed to return the message without the PART wrapper element, since this element is not // transmitted in the SOAP messages on the wire //return (Element) DOMUtils.findChildByName(response, new QName("",bpelOperationOutputPart.getName())); -- cgit v1.2.3