- public void onMessage(Message message, Session session) throws JMSException {
- MessageProducer producer = session.createProducer(responseDestination);
- String query = message.getStringProperty(PROPERTY_QUERY);
- String correlationId = message.getJMSCorrelationID();
- if (log.isDebugEnabled())
- log.debug("Received query " + query + " with correlationId "
- + correlationId);
-
- Message responseMsg = null;
- if ("getExecutionModuleDescriptor".equals(query)) {
- String moduleName = message.getStringProperty("moduleName");
- String version = message.getStringProperty("version");
- ExecutionModuleDescriptor emd = getExecutionModuleDescriptor(
- moduleName, version);
- responseMsg = jmsTemplate.getMessageConverter().toMessage(emd,
- session);
- } else if ("listExecutionModuleDescriptors".equals(query)) {
-
- List<ExecutionModuleDescriptor> lst = listExecutionModuleDescriptors();
- SlcAgentDescriptor agentDescriptorToSend = new SlcAgentDescriptor(
- agentDescriptor);
- agentDescriptorToSend.setModuleDescriptors(lst);
- responseMsg = jmsTemplate.getMessageConverter().toMessage(
- agentDescriptorToSend, session);
- } else if ("newExecution".equals(query)) {
-
- SlcExecution slcExecution = (SlcExecution) jmsTemplate
- .getMessageConverter().fromMessage(message);
- runSlcExecution(slcExecution);
- return;
- } else {
- // try {
- // // FIXME: generalize
- // SlcExecution slcExecution = (SlcExecution) jmsTemplate
- // .getMessageConverter().fromMessage(message);
- // runSlcExecution(slcExecution);
- // } catch (MessageConversionException e) {
- // if (log.isDebugEnabled())
- // log.debug("Unsupported query " + query, e);
- // }
- if (log.isDebugEnabled())
- log.debug("Unsupported query " + query);
- return;
+ 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);