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
.core
.process
.SlcExecution
;
6 import org
.argeo
.slc
.dao
.process
.SlcExecutionDao
;
7 import org
.argeo
.slc
.msg
.process
.SlcExecutionRequest
;
8 import org
.springframework
.ws
.server
.endpoint
.AbstractMarshallingPayloadEndpoint
;
10 public class SlcExecutionRequestEp
extends AbstractMarshallingPayloadEndpoint
{
12 private Log log
= LogFactory
.getLog(getClass());
14 private final SlcExecutionDao slcExecutionDao
;
16 public SlcExecutionRequestEp(SlcExecutionDao slcExecutionDao
) {
17 this.slcExecutionDao
= slcExecutionDao
;
21 protected Object
invokeInternal(Object requestObject
) throws Exception
{
22 SlcExecutionRequest msg
= (SlcExecutionRequest
) requestObject
;
23 SlcExecution slcExecution
= msg
.getSlcExecution();
25 if (slcExecutionDao
.getSlcExecution(slcExecution
.getUuid()) == null) {
26 slcExecutionDao
.create(slcExecution
);
28 if (log
.isDebugEnabled())
29 log
.debug("Created SlcExecution with uuid "
30 + slcExecution
.getUuid());
32 slcExecutionDao
.update(slcExecution
);
34 if (log
.isDebugEnabled())
35 log
.debug("Updated SlcExecution with uuid "
36 + slcExecution
.getUuid());