1 package org
.argeo
.slc
.ws
.process
;
3 import org
.apache
.commons
.logging
.Log
;
4 import org
.apache
.commons
.logging
.LogFactory
;
5 import org
.argeo
.slc
.dao
.process
.SlcExecutionDao
;
6 import org
.argeo
.slc
.msg
.process
.SlcExecutionStepsRequest
;
7 import org
.argeo
.slc
.process
.SlcExecutionStep
;
8 import org
.springframework
.ws
.server
.endpoint
.AbstractMarshallingPayloadEndpoint
;
10 public class SlcExecutionStepsRequestEp
extends
11 AbstractMarshallingPayloadEndpoint
{
13 private Log log
= LogFactory
.getLog(getClass());
15 private final SlcExecutionDao slcExecutionDao
;
17 public SlcExecutionStepsRequestEp(SlcExecutionDao slcExecutionDao
) {
18 this.slcExecutionDao
= slcExecutionDao
;
22 protected Object
invokeInternal(Object requestObject
) throws Exception
{
25 SlcExecutionStepsRequest msg
= (SlcExecutionStepsRequest
) requestObject
;
26 uuid
= msg
.getSlcExecutionUuid();
27 if (log
.isTraceEnabled()) {
28 log
.trace("Trying to add additional steps to SLC execution #"
30 for (SlcExecutionStep step
: msg
.getSteps()) {
31 log
.trace("Step " + step
.getUuid() + " (in SLC execution #"
34 log
.trace("Adding " + msg
.getSteps().size()
35 + " steps to SLC execution #" + uuid
);
38 slcExecutionDao
.addSteps(uuid
, msg
.getSteps());
40 } catch (Exception e
) {
41 log
.error("Could not update SLC execution #" + uuid
42 + " with additional steps", e
);