X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.server%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fservices%2Fimpl%2FSlcExecutionServiceAdapter.java;h=b1abbeef1ecbcbe12c29e00e648c60bbecbc16be;hb=a181e3d059185a9dc108e81f38c66f48f4e4aac8;hp=a007e6ce57d312107bb04ae0233e6f2b12f03a91;hpb=041d60f64b902ebc33f9ec817096dc913233eecd;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/services/impl/SlcExecutionServiceAdapter.java b/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/services/impl/SlcExecutionServiceAdapter.java index a007e6ce5..b1abbeef1 100644 --- a/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/services/impl/SlcExecutionServiceAdapter.java +++ b/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/services/impl/SlcExecutionServiceAdapter.java @@ -18,39 +18,43 @@ package org.argeo.slc.services.impl; import java.util.List; -import org.argeo.slc.UnsupportedException; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.argeo.slc.execution.ExecutionProcess; import org.argeo.slc.msg.process.SlcExecutionStatusRequest; import org.argeo.slc.msg.process.SlcExecutionStepsRequest; -import org.argeo.slc.process.SlcExecution; import org.argeo.slc.process.SlcExecutionNotifier; import org.argeo.slc.process.SlcExecutionStep; import org.argeo.slc.services.SlcExecutionService; /** In memory bridge between SLC execution notifier and service. */ +@SuppressWarnings("deprecation") public class SlcExecutionServiceAdapter implements SlcExecutionNotifier { + private final static Log log = LogFactory + .getLog(SlcExecutionServiceAdapter.class); + private SlcExecutionService slcExecutionService; - public void updateStatus(SlcExecution slcExecution, String oldStatus, + public void updateStatus(ExecutionProcess slcExecution, String oldStatus, String newStatus) { SlcExecutionStatusRequest req = new SlcExecutionStatusRequest( slcExecution.getUuid(), newStatus); - slcExecutionService.updateStatus(req); + try { + slcExecutionService.updateStatus(req); + } catch (Exception e) { + log.trace("Cannot update process status " + e); + } } - public void addSteps(SlcExecution slcExecution, + public void addSteps(ExecutionProcess slcExecution, List additionalSteps) { SlcExecutionStepsRequest req = new SlcExecutionStepsRequest( slcExecution.getUuid(), additionalSteps); - slcExecutionService.addSteps(req); - } - - public void newExecution(SlcExecution slcExecution) { - throw new UnsupportedException(); - //slcExecutionService.newExecution(slcExecution); - } - - public void updateExecution(SlcExecution slcExecution) { - throw new UnsupportedException(); + try { + slcExecutionService.addSteps(req); + } catch (Exception e) { + log.trace("Cannot add steps " + e); + } } public void setSlcExecutionService(SlcExecutionService slcExecutionService) {