Centralize MySQL config

[gpl/argeo-slc.git] / runtime / org.argeo.slc.support.activemq / src / main / java / org / argeo / slc / jms / JmsTransferNewExecution.java

diff --git a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTransferNewExecution.java b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTransferNewExecution.java
new file mode 100644 (file)
index 0000000..856b956
--- /dev/null
+++ b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTransferNewExecution.java
@@ -0,0 +1,34 @@
+package org.argeo.slc.jms;
+
+import java.util.UUID;
+
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+
+import org.springframework.jms.listener.SessionAwareMessageListener;
+
+/** Temporary hack*/
+public class JmsTransferNewExecution implements SessionAwareMessageListener {
+       private Destination requestDestination;
+
+       public void onMessage(Message message, Session session) throws JMSException {
+               TextMessage messageToSend = session
+                               .createTextMessage(((TextMessage) message).getText());
+               messageToSend
+                               .setStringProperty(JmsAgent.PROPERTY_QUERY, "newExecution");
+               messageToSend.setStringProperty(JmsAgent.PROPERTY_SLC_AGENT_ID, message
+                               .getStringProperty(JmsAgent.PROPERTY_SLC_AGENT_ID));
+               messageToSend.setJMSCorrelationID(UUID.randomUUID().toString());
+               MessageProducer producer = session.createProducer(requestDestination);
+               producer.send(messageToSend);
+       }
+
+       public void setRequestDestination(Destination requestDestination) {
+               this.requestDestination = requestDestination;
+       }
+
+}