if (requestObject instanceof SlcExecutionRequest) {
SlcExecutionRequest msg = (SlcExecutionRequest) requestObject;
- SlcExecution slcExecution = msg.getSlcExecution();
+ SlcExecution slcExecutionMsg = msg.getSlcExecution();
- if (slcExecutionDao.getSlcExecution(slcExecution.getUuid()) == null) {
- if (log.isDebugEnabled())
- log.debug("Creating SlcExecution with uuid "
- + slcExecution.getUuid());
+ SlcExecution slcExecutionPersisted = slcExecutionDao
+ .getSlcExecution(slcExecutionMsg.getUuid());
+ if (slcExecutionPersisted == null) {
+ if (log.isTraceEnabled())
+ log.trace("Creating SLC execution #"
+ + slcExecutionMsg.getUuid());
- slcExecutionDao.create(slcExecution);
+ slcExecutionDao.create(slcExecutionMsg);
} else {
- if (log.isDebugEnabled())
- log.debug("Updating SlcExecution with uuid "
- + slcExecution.getUuid());
+ if (log.isTraceEnabled())
+ log.trace("Updating SLC execution #"
+ + slcExecutionMsg.getUuid());
- slcExecutionDao.update(slcExecution);
+ slcExecutionDao.merge(slcExecutionMsg);
}
return null;
SlcExecutionStatusRequest msg = (SlcExecutionStatusRequest) requestObject;
SlcExecution slcExecution = slcExecutionDao.getSlcExecution(msg
.getSlcExecutionUuid());
+ if (slcExecution == null)
+ throw new SlcException("Could not find SLC execution #"
+ + msg.getSlcExecutionUuid());
+
slcExecution.setStatus(msg.getNewStatus());
+
+ if (log.isTraceEnabled())
+ log.trace("Updating status for SLC execution #"
+ + slcExecution.getUuid());
+
slcExecutionDao.update(slcExecution);
return null;
} else {
+ requestObject.getClass());
}
}
-
}