activeMQjava的简单demo例子

/* * To change this template, choose Tools | Templates * and open the template in the editor. */ package com.wh.mq; import java.nio.ByteBuffer; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.Session; import org.apache.activemq.command.ActiveMQQueue; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.core.MessageCreator; import org.springframework.jms.core.MessagePostProcessor; /** * 发送MQ消息队列 * @author Administrator */ public class SendMessage { private ActiveMQQueue destination; private JmsTemplate jmsTemplate; /** * 发送消息 * @param buffer 待发送的byteBuffer数据对象 * 备注：因为ByteBuffer没有实现Serializable接口，所以需要单独写方法 */ public void sendMessage(final ByteBuffer buffer) { MessageCreator messageCreator = new MessageCreator() { @Override public Message createMessage(Session sn) throws JMSException { javax.jms.BytesMessage message = sn.createBytesMessage(); message.setStringProperty("JMSXGroupID", "My_Demo_Message"); message.writeBytes(buffer.array()); // message.writeObject(buffer);//因为byteBuffer不是没有实现Serializable接口，所以写入会报错 return message; } }; jmsTemplate.send(destination, messageCreator); } /** * 发送消息 * @param o 实现了Serializable接口的对象 */ public void sendMessage(final Object o) { MessagePostProcessor post = new MessagePostProcessor() { @Override public Message postProcessMessage(Message msg) throws JMSException { //发送消息到指定队列组 msg.setStringProperty("JMSXGroupID", "My_Demo_Message"); return msg; } }; jmsTemplate.convertAndSend(destination, o, post); // jmsTemplate.convertAndSend(destination, o); } public ActiveMQQueue getDestination() { return destination; } public void setDestination(ActiveMQQueue destination) { this.destination = destination; } public JmsTemplate getJmsTemplate() { return jmsTemplate; } public void setJmsTemplate(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } }