JMS监听MQ实例
jsm_applicationContext.xml配置

public class JmsManager {  private JmsTemplate jmsTemplate;  public void sendMessage(final String msg){    BeanFactory factory = new ClassPathXmlApplicationContext("jms_applicationContext.xml");    Destination destination = (Destination)factory.getBean("sendQueue");    jmsTemplate.send(destination, new MessageCreator(){      public Message createMessage(Session session) throws JMSException {        BytesMessage message = session.createBytesMessage();        try {          message.writeBytes(msg.getBytes("UTF-8");        } catch (UnsupportedEncodingException e) {}        return message;      }    });  }  public byte[] getMessage(){    byte[] msg = (byte[])null;    BeanFactory factory = new ClassPathXmlApplicationContext("jms_applicationContext.xml");    Destination destination = (Destination)factory.getBean("acceptQueue");    Message message = jmsTemplate.receive(destination);    try{      if(message instanceof TextMessage){        msg = ((TextMessage)message).getText().getBytes();        return msg;      }      if(message instanceof BytesMessage){        BytesMessage bMsg = (BytesMessage)message;        msg = new byte[(int)bMsg.getBodyLength()];        bMsg.readBytes(msg);        return msg;      }      if(message instanceof ObjectMessage){        ObjectMessage oMsg = (ObjectMessage)message;        msg = (byte[])oMsg.getObject();        return msg;      }    } catch (JMSException e) {      e.printStackTrace();    }    return msg;  }}