ActiveMQ与Spring线程池整合实例

/** * */ package com.jmspool.jms; import java.util.HashMap; import java.util.Map; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.ObjectMessage; import javax.jms.Session; import org.apache.activemq.command.ActiveMQObjectMessage; import org.springframework.jms.support.converter.MessageConversionException; import org.springframework.jms.support.converter.MessageConverter; import com.jmspool.pool.ThreadPoolTask; /** * @author 张磊 * */ public class ResourceMessageConverter implements MessageConverter { /* （非 Javadoc） * @see org.springframework.jms.support.converter.MessageConverter#fromMessage(javax.jms.Message) */ public Object fromMessage(Message message) throws JMSException, MessageConversionException { return ((Map) ((ObjectMessage) message).getObjectProperty("Tasks")).get("Task"); } /* （非 Javadoc） * @see org.springframework.jms.support.converter.MessageConverter#toMessage(java.lang.Object, javax.jms.Session) */ public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException { //JMS消息 ActiveMQObjectMessage message = (ActiveMQObjectMessage) session.createObjectMessage(); Map<String, ThreadPoolTask> map = new HashMap<String, ThreadPoolTask>(); map.put("Task", (ThreadPoolTask) object); message.setObjectProperty("Tasks", map); return message; } }