X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;ds=inline;f=org.argeo.slc.runtime%2Fsrc%2Forg%2Fargeo%2Fslc%2Fruntime%2FDefaultExecutionFlow.java;h=9e31306adf765d2c35c9f2d0ed3c3fa20ff9652f;hb=fbe96810dae8085b3d6935d085d21008fb809fc3;hp=f99ce9d7148d1a865f88409620857ec13820d9a8;hpb=58b35f147f3c1c1a12a07c303105618f679c7161;p=gpl%2Fargeo-slc.git diff --git a/org.argeo.slc.runtime/src/org/argeo/slc/runtime/DefaultExecutionFlow.java b/org.argeo.slc.runtime/src/org/argeo/slc/runtime/DefaultExecutionFlow.java index f99ce9d71..9e31306ad 100644 --- a/org.argeo.slc.runtime/src/org/argeo/slc/runtime/DefaultExecutionFlow.java +++ b/org.argeo.slc.runtime/src/org/argeo/slc/runtime/DefaultExecutionFlow.java @@ -1,13 +1,15 @@ package org.argeo.slc.runtime; +import static java.lang.System.Logger.Level.ERROR; +import static java.lang.System.Logger.Level.WARNING; + +import java.lang.System.Logger.Level; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.argeo.slc.SlcException; import org.argeo.slc.execution.ExecutionContext; import org.argeo.slc.execution.ExecutionFlow; @@ -16,7 +18,7 @@ import org.argeo.slc.execution.ExecutionSpecAttribute; /** Default implementation of an execution flow. */ public class DefaultExecutionFlow implements ExecutionFlow { - private final static Log log = LogFactory.getLog(DefaultExecutionFlow.class); + private final static System.Logger logger = System.getLogger(DefaultExecutionFlow.class.getName()); private final ExecutionSpec executionSpec; private String name = null; @@ -84,7 +86,7 @@ public class DefaultExecutionFlow implements ExecutionFlow { try { for (Runnable executable : executables) { if (Thread.interrupted()) { - log.error("Flow '" + getName() + "' killed before '" + executable + "'"); + logger.log(ERROR, "Flow '" + getName() + "' killed before '" + executable + "'"); Thread.currentThread().interrupt(); return; // throw new ThreadDeath(); @@ -93,7 +95,7 @@ public class DefaultExecutionFlow implements ExecutionFlow { } } catch (RuntimeException e) { if (Thread.interrupted()) { - log.error("Flow '" + getName() + "' killed while receiving an unrelated exception", e); + logger.log(ERROR, "Flow '" + getName() + "' killed while receiving an unrelated exception", e); Thread.currentThread().interrupt(); return; // throw new ThreadDeath(); @@ -101,9 +103,9 @@ public class DefaultExecutionFlow implements ExecutionFlow { if (failOnError) throw e; else { - log.error("Execution flow failed," + " but process did not fail" + " because failOnError property" - + " is set to false: " + e); - if (log.isTraceEnabled()) + logger.log(ERROR, "Execution flow failed," + " but process did not fail" + + " because failOnError property" + " is set to false: " + e); + if (logger.isLoggable(Level.TRACE)) e.printStackTrace(); } } @@ -156,7 +158,7 @@ public class DefaultExecutionFlow implements ExecutionFlow { DefaultExecutionFlow flow = (DefaultExecutionFlow) executable; String newPath = path + '/' + flow.getName(); flow.setPath(newPath); - log.warn(newPath + " was forcibly set on " + flow); + logger.log(WARNING, newPath + " was forcibly set on " + flow); } } }