gCubeSystem
/
social-data-indexer-se-plugin
16
1
Fork 0
Code Issues Pull Requests Releases Wiki Activity

send notification only on failures 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/social-networking/social-data-indexer-se-plugin@144776 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Costantino Perciante 2017-03-09 09:01:26 +00:00
parent 26020247a9
commit 73c1332611
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/org/gcube/socialnetworking/socialdataindexer/utils/SendNotification.java
View File

@ -59,7 +59,7 @@ public class SendNotification extends PluginStateNotification {
switch(pluginStateEvolution.getPluginState()){
case DONE:
// case DONE:
case STOPPED:
case FAILED:
case DISCARDED:
@ -81,13 +81,13 @@ public class SendNotification extends PluginStateNotification {
obj.put("recipient", recipient);
obj.put("job_name", pluginStateEvolution.getPluginDeclaration().getName());
obj.put("service_name", SERVICE_NAME);
if(pluginStateEvolution.getPluginState().equals(PluginState.DONE))
obj.put("status", "SUCCEEDED");
else{
obj.put("status", "FAILED");
obj.put("status_message", "original status reported by " + SERVICE_NAME + " was " + pluginStateEvolution.getPluginState()
+ ". Exception is " + exception != null ? exception.getMessage() : null);
}
// if(pluginStateEvolution.getPluginState().equals(PluginState.DONE))
// obj.put("status", "SUCCEEDED");
// else{
obj.put("status", "FAILED");
obj.put("status_message", "original status reported by " + SERVICE_NAME + " was " + pluginStateEvolution.getPluginState()
+ ". Exception is " + exception != null ? exception.getMessage() : null);
// }
logger.debug("Request json is going to be " + obj.toJSONString());
HttpResponse response = performRequest(httpClient, basePath, obj.toJSONString());