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 executionEventDestination
;
20 //private Destination updateStatusDestination;
22 public void updateStatus(SlcExecution slcExecution
, String oldStatus
,
24 SlcExecutionStatusRequest req
= new SlcExecutionStatusRequest(
25 slcExecution
.getUuid(), newStatus
);
26 jmsTemplate
.convertAndSend(executionEventDestination
, req
);
29 public void addSteps(SlcExecution slcExecution
,
30 List
<SlcExecutionStep
> additionalSteps
) {
31 throw new UnsupportedException();
34 public void newExecution(SlcExecution slcExecution
) {
35 throw new UnsupportedException();
38 public void updateExecution(SlcExecution slcExecution
) {
39 throw new UnsupportedException();
42 public void setJmsTemplate(JmsTemplate jmsTemplate
) {
43 this.jmsTemplate
= jmsTemplate
;
46 public void setExecutionEventDestination(Destination executionEventDestination
) {
47 this.executionEventDestination
= executionEventDestination
;
52 // public void setUpdateStatusDestination(Destination updateStatusDestination) {
53 // this.updateStatusDestination = updateStatusDestination;