X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fexecution%2FExecutionThread.java;h=9190ea6fc1647c38d097390fff116237322de466;hb=62fa7073046d9581413d87aa6025de74bd4b669c;hp=d8c7289894db3f353487b62a92ff0a8405fcb39a;hpb=1fdb1b4e7b1d2b0cabb6483238301b857a6392fa;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ExecutionThread.java b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ExecutionThread.java
index d8c728989..9190ea6fc 100644
--- a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ExecutionThread.java
+++ b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ExecutionThread.java
@@ -51,7 +51,7 @@ public class ExecutionThread extends Thread {
 				.getFlowDescriptor();
 		String flowName = executionFlowDescriptor.getName();
 
-		dispatchAddStep(new SlcExecutionStep(SlcExecutionStep.TYPE_PHASE_START,
+		dispatchAddStep(new SlcExecutionStep(SlcExecutionStep.PHASE_START,
 				"Flow " + flowName));
 
 		try {
@@ -65,12 +65,13 @@ public class ExecutionThread extends Thread {
 			// TODO: re-throw exception ?
 			String msg = "Execution of flow " + flowName + " failed.";
 			log.error(msg, e);
-			dispatchAddStep(new SlcExecutionStep(msg + " " + e.getMessage()));
+			dispatchAddStep(new SlcExecutionStep(SlcExecutionStep.ERROR, msg
+					+ " " + e.getMessage()));
 			processThread.notifyError();
 		} finally {
 			processThread.flowCompleted();
-			dispatchAddStep(new SlcExecutionStep(
-					SlcExecutionStep.TYPE_PHASE_END, "Flow " + flowName));
+			dispatchAddStep(new SlcExecutionStep(SlcExecutionStep.PHASE_END,
+					"Flow " + flowName));
 		}
 	}