+ public boolean ping() {
+ return true;
+ }
+
+ public void onMessage(final Message message) {
+ final String query;
+ final String correlationId;
+ try {
+ query = message.getStringProperty(PROPERTY_QUERY);
+ correlationId = message.getJMSCorrelationID();
+ } catch (JMSException e1) {
+ throw new SlcException("Cannot analyze incoming message " + message);
+ }
+
+ final Object response = process(query, message);
+
+ new Thread() {
+ public void run() {
+ // Send response
+ jmsTemplate.convertAndSend(responseDestination, response,
+ new MessagePostProcessor() {
+ public Message postProcessMessage(
+ Message messageToSend) throws JMSException {
+ messageToSend
+ .setStringProperty(
+ PROPERTY_QUERY,
+ message
+ .getStringProperty(PROPERTY_QUERY));
+ messageToSend.setStringProperty(
+ PROPERTY_SLC_AGENT_ID, agentDescriptor
+ .getUuid());
+ messageToSend.setJMSCorrelationID(message
+ .getJMSCorrelationID());
+ return messageToSend;
+ }
+ });
+ if (log.isDebugEnabled())
+ log.debug("Sent response to query " + query
+ + " with correlationId " + correlationId);
+ }
+ }.start();
+
+ }
+
+ /** @return response */
+ public Object process(String query, Message message) {
+ try {
+ if ("getExecutionModuleDescriptor".equals(query)) {
+ String moduleName = message.getStringProperty("moduleName");
+ String version = message.getStringProperty("version");
+ return getExecutionModuleDescriptor(moduleName, version);
+ } else if ("listExecutionModuleDescriptors".equals(query)) {
+
+ List<ExecutionModuleDescriptor> lst = listExecutionModuleDescriptors();
+ SlcAgentDescriptor agentDescriptorToSend = new SlcAgentDescriptor(
+ agentDescriptor);
+ agentDescriptorToSend.setModuleDescriptors(lst);
+ return agentDescriptorToSend;
+ } else if ("runSlcExecution".equals(query)) {
+ SlcExecution slcExecution = (SlcExecution) convertFrom(message);
+ runSlcExecution(slcExecution);
+ return ExecutionAnswer.ok("Execution started on agent "
+ + agentDescriptor.getUuid());
+ } else if ("ping".equals(query)) {
+ return ExecutionAnswer.ok("Agent " + agentDescriptor.getUuid()
+ + " is alive.");
+ } else {
+ throw new SlcException("Unsupported query " + query);
+ }
+ } catch (Exception e) {
+ log.error("Processing of query " + query + " failed", e);
+ return ExecutionAnswer.error(e);
+ }
+ }
+
+ protected Object convertFrom(Message message) throws JMSException {
+ return jmsTemplate.getMessageConverter().fromMessage(message);
+ }
+