+ @After("execution(void org.argeo.slc.services.SlcExecutionService.newExecution(..))")
+ public void newSlcExecution(JoinPoint jp) throws Throwable {
+ SlcExecution slcExecution = (SlcExecution) jp.getArgs()[0];
+ SlcEvent event = new SlcEvent(EVT_NEW_SLC_EXECUTION);
+ event.getHeaders().put(MsgConstants.PROPERTY_SLC_EXECUTION_ID,
+ slcExecution.getUuid());
+ publishEvent(event);
+ }
+
+ @After("execution(void org.argeo.slc.services.SlcExecutionService.updateStatus(..))")
+ public void updateSlcExecutionStatus(JoinPoint jp) throws Throwable {
+ SlcExecutionStatusRequest msg = (SlcExecutionStatusRequest) jp
+ .getArgs()[0];
+ SlcEvent event = new SlcEvent(EVT_UPDATE_SLC_EXECUTION_STATUS);
+ event.getHeaders().put(MsgConstants.PROPERTY_SLC_EXECUTION_ID,
+ msg.getSlcExecutionUuid());
+ event.getHeaders().put(MsgConstants.PROPERTY_SLC_EXECUTION_STATUS,
+ msg.getNewStatus());
+ publishEvent(event);
+ }
+