You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2013/01/09 02:46:32 UTC
svn commit: r1430651 -
/airavata/trunk/modules/gfac-axis2/src/main/java/org/apache/airavata/services/gfac/axis2/reciever/GFacMessageReciever.java
Author: lahiru
Date: Wed Jan 9 01:46:32 2013
New Revision: 1430651
URL: http://svn.apache.org/viewvc?rev=1430651&view=rev
Log:
fixing https://issues.apache.org/jira/browse/AIRAVATA-708.
Modified:
airavata/trunk/modules/gfac-axis2/src/main/java/org/apache/airavata/services/gfac/axis2/reciever/GFacMessageReciever.java
Modified: airavata/trunk/modules/gfac-axis2/src/main/java/org/apache/airavata/services/gfac/axis2/reciever/GFacMessageReciever.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/gfac-axis2/src/main/java/org/apache/airavata/services/gfac/axis2/reciever/GFacMessageReciever.java?rev=1430651&r1=1430650&r2=1430651&view=diff
==============================================================================
--- airavata/trunk/modules/gfac-axis2/src/main/java/org/apache/airavata/services/gfac/axis2/reciever/GFacMessageReciever.java (original)
+++ airavata/trunk/modules/gfac-axis2/src/main/java/org/apache/airavata/services/gfac/axis2/reciever/GFacMessageReciever.java Wed Jan 9 01:46:32 2013
@@ -200,10 +200,10 @@ public class GFacMessageReciever impleme
//// invocationContext.getExecutionContext().setSecurityContextHeader(header);
// //todo if there's amazoneWebServices context we need to set that value, this will refer in EC2Provider
// }else {
+ try {
+
gfacAPI = new GfacAPI();
invocationContext = gfacAPI.gridJobSubmit(jobContext, (GFacConfiguration) context.getProperty(GFacService.GFAC_CONFIGURATION));
-// }
- try {
/*
* Add notifiable object
*/
@@ -226,9 +226,21 @@ public class GFacMessageReciever impleme
}
} catch (Exception e) {
+ OMFactory fac = OMAbstractFactory.getOMFactory();
+ OMNamespace omNs = fac.createOMNamespace("http://ws.apache.org/axis2/xsd", "ns1");
+ outputElement = fac.createOMElement("ErrorResponse", omNs);
+ outputElement.setText("Invocation failed" + e.getMessage());
log.error("Error in invoking service", e);
+ SOAPFactory sf = OMAbstractFactory.getSOAP11Factory();
+ SOAPEnvelope responseEnv = sf.createSOAPEnvelope();
+ sf.createSOAPBody(responseEnv);
+ responseEnv.getBody().addChild(outputElement);
+ MessageContext outMessageContext = MessageContextBuilder.createOutMessageContext(messageContext);
+ outMessageContext.setEnvelope(responseEnv);
+ AxisEngine.send(outMessageContext);
throw e;
}
+// }
SOAPFactory sf = OMAbstractFactory.getSOAP11Factory();
SOAPEnvelope responseEnv = sf.createSOAPEnvelope();