svn commit: r1393738 - in /airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac: exception/JobSubmissionFault.java provider/impl/GramProvider.java

[lahiru]

Author: lahiru
Date: Wed Oct  3 20:00:41 2012
New Revision: 1393738

URL: http://svn.apache.org/viewvc?rev=1393738&view=rev
Log:
fixing error handling issue in airavata.

Modified:
    
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java
    
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java

Modified: 
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java
URL: 
http://svn.apache.org/viewvc/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java?rev=1393738&r1=1393737&r2=1393738&view=diff
==============================================================================
--- 
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java
 (original)
+++ 
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java
 Wed Oct  3 20:00:41 2012
@@ -42,4 +42,13 @@ public class JobSubmissionFault extends 
     public void setReason(String reason) {
         this.reason = reason;
     }
+
+    public void sendFaultNotification(String message,
+                       InvocationContext invocationContext, Exception e,
+                       String... additionalExceptiondata) {
+               if (additionalExceptiondata==null || 
additionalExceptiondata.length==0){
+               additionalExceptiondata=new 
String[]{message,e.getLocalizedMessage()};
+        }
+               
invocationContext.getExecutionContext().getNotifier().executionFail(invocationContext,e,additionalExceptiondata);
+       }
 }

Modified: 
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java
URL: 
http://svn.apache.org/viewvc/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java?rev=1393738&r1=1393737&r2=1393738&view=diff
==============================================================================
--- 
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java
 (original)
+++ 
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java
 Wed Oct  3 20:00:41 2012
@@ -228,6 +228,7 @@ public class GramProvider extends Abstra
          } catch (GramException e) {
             JobSubmissionFault error = new JobSubmissionFault(this, e, 
host.getHostAddress(), gateKeeper, job.getRSL(), invocationContext);
             int errCode = listener.getError();
+            
error.sendFaultNotification(error.getMessage(),invocationContext,error,host.getHostAddress()+
 "," + job.getRSL());
                    throw errorReason(errCode, error);
         } catch (GSSException e) {
             throw new ProviderException(e.getMessage(), e, invocationContext);