1 package org
.argeo
.slc
.jms
;
5 import javax
.jms
.Destination
;
7 import org
.argeo
.slc
.SlcException
;
8 import org
.argeo
.slc
.UnsupportedException
;
9 import org
.argeo
.slc
.msg
.process
.SlcExecutionStatusRequest
;
10 import org
.argeo
.slc
.process
.SlcExecution
;
11 import org
.argeo
.slc
.process
.SlcExecutionNotifier
;
12 import org
.argeo
.slc
.process
.SlcExecutionStep
;
13 import org
.springframework
.jms
.core
.JmsTemplate
;
15 public class JmsSlcExecutionNotifier
implements SlcExecutionNotifier
{
17 private JmsTemplate jmsTemplate
;
19 private Destination updateStatusDestination
;
21 public void updateStatus(SlcExecution slcExecution
, String oldStatus
,
23 SlcExecutionStatusRequest req
= new SlcExecutionStatusRequest(
24 slcExecution
.getUuid(), newStatus
);
25 jmsTemplate
.convertAndSend(updateStatusDestination
, req
);
28 public void addSteps(SlcExecution slcExecution
,
29 List
<SlcExecutionStep
> additionalSteps
) {
30 throw new UnsupportedException();
33 public void newExecution(SlcExecution slcExecution
) {
34 throw new UnsupportedException();
37 public void updateExecution(SlcExecution slcExecution
) {
38 throw new UnsupportedException();
41 public void setJmsTemplate(JmsTemplate jmsTemplate
) {
42 this.jmsTemplate
= jmsTemplate
;
45 public void setUpdateStatusDestination(Destination updateStatusDestination
) {
46 this.updateStatusDestination
= updateStatusDestination
;