svn commit: r1430651 - /airavata/trunk/modules/gfac-axis2/src/main/java/org/apache/airavata/services/gfac/axis2/reciever/GFacMessageReciever.java

[lahiru]

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();