X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsSlcExecutionNotifier.java;h=801c6fae32a730fc9204dde886ec931f8e8b9cf5;hb=304125ea23a3570c78149816d76951bbb258707d;hp=5bdefc823fca1fcca954c2a7d448d533aa10ee65;hpb=693cc53b426d088e49d746585bf7c5e197fc3998;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsSlcExecutionNotifier.java b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsSlcExecutionNotifier.java index 5bdefc823..801c6fae3 100644 --- a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsSlcExecutionNotifier.java +++ b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsSlcExecutionNotifier.java @@ -16,13 +16,14 @@ public class JmsSlcExecutionNotifier implements SlcExecutionNotifier { private JmsTemplate jmsTemplate; - private Destination updateStatusDestination; + private Destination executionEventDestination; + //private Destination updateStatusDestination; public void updateStatus(SlcExecution slcExecution, String oldStatus, String newStatus) { SlcExecutionStatusRequest req = new SlcExecutionStatusRequest( slcExecution.getUuid(), newStatus); - jmsTemplate.convertAndSend(updateStatusDestination, req); + jmsTemplate.convertAndSend(executionEventDestination, req); } public void addSteps(SlcExecution slcExecution, @@ -42,8 +43,14 @@ public class JmsSlcExecutionNotifier implements SlcExecutionNotifier { this.jmsTemplate = jmsTemplate; } - public void setUpdateStatusDestination(Destination updateStatusDestination) { - this.updateStatusDestination = updateStatusDestination; + public void setExecutionEventDestination(Destination executionEventDestination) { + this.executionEventDestination = executionEventDestination; } + + +// public void setUpdateStatusDestination(Destination updateStatusDestination) { +// this.updateStatusDestination = updateStatusDestination; +// } + }