runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsExecutionHandler.java

   1 package org.argeo.slc.jms;
   2
   3 import javax.jms.JMSException;
   4 import javax.jms.Message;
   5 import javax.jms.MessageListener;
   6
   7 import org.argeo.slc.SlcException;
   8 import org.argeo.slc.msg.MsgHandler;
   9 import org.springframework.jms.support.converter.MessageConverter;
  10
  11 public class JmsExecutionHandler implements MessageListener {
  12
  13         private MessageConverter messageConverter;
  14         private MsgHandler serviceMsgHandler;
  15
  16         public void onMessage(Message message) {
  17                 try {
  18                         serviceMsgHandler.handleMsg(messageConverter.fromMessage(message));
  19                 } catch (JMSException e) {
  20                         throw new SlcException("Could not interpret message " + message, e);
  21                 }
  22         }
  23
  24         public void setMessageConverter(MessageConverter messageConverter) {
  25                 this.messageConverter = messageConverter;
  26         }
  27
  28         public void setServiceMsgHandler(MsgHandler serviceMsgHandler) {
  29                 this.serviceMsgHandler = serviceMsgHandler;
  30         }
  31
  32 }