package activemq.demo;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.HashMap;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import org.apache.activemq.command.ActiveMQObjectMessage;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.jms.support.converter.MessageConverter;
public class DefaultMessageConverter implements MessageConverter {
/**
* Logger for this class
*/
private static final Log log = LogFactory.getLog(DefaultMessageConverter.class);
public Message toMessage(Object obj, Session session) throws JMSException {
if (log.isDebugEnabled()) {
log.debug("toMessage(Object, Session) - start");
}
// check Type
ActiveMQObjectMessage objMsg = (ActiveMQObjectMessage) session.createObjectMessage();
HashMap<String, byte[]> map = new HashMap<String, byte[]>();
try {
// POJO must implements Seralizable
ByteArrayOutputStream bos = new ByteArrayOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(bos);
oos.writeObject(obj);
map.put("POJO", bos.toByteArray());
objMsg.setObjectProperty("Map", map);
} catch (IOException e) {
log.error("toMessage(Object, Session)", e);
}
return objMsg;
}
public Object fromMessage(Message msg) throws JMSException {
if (log.isDebugEnabled()) {
log.debug("fromMessage(Message) - start");
}
if (msg instanceof ObjectMessage) {
HashMap<String, byte[]> map = (HashMap<String, byte[]>) ((ObjectMessage) msg).getObjectProperty("Map");
try {
// POJO must implements Seralizable
ByteArrayInputStream bis = new ByteArrayInputStream(map.get("POJO"));
ObjectInputStream ois = new ObjectInputStream(bis);
Object returnObject = ois.readObject();
return returnObject;
} catch (IOException e) {
log.error("fromMessage(Message)", e);
} catch (ClassNotFoundException e) {
log.error("fromMessage(Message)", e);
}
return null;
} else {
throw new JMSException("Msg:[" + msg + "] is not Map");
}
}
}
ActiveMQ5.1+Spring2.5 Demo
4星 · 超过85%的资源 需积分: 0 176 浏览量
2008-09-10
11:38:14
上传
评论 1
收藏 36KB RAR 举报 
ActiveMQ5.1-Spring-Demo.rar （32个子文件） 
ActiveMQ5.1-Spring-Demo 
.project 399B bin log4j.properties 279B applicationContext.xml 2KB activemq demo ResourceMessageConverter.class 2KB Book.class 1KB ResourceMessageConsumer.class 1KB Run.class 1KB DefaultMessageConverter.class 3KB ResourceMessageProducer.class 2KB .settings org.springframework.ide.eclipse.core.prefs 6KB activemq-data localhost lock 0B journal data-1 31.5MB data-control 2KB tmp_storage kr-store state index-transactions-state 51B data-store-state-1 3KB lock 0B data-kaha-1 290B index-kaha 306B index-store-state 204B hash-index-store-state_state 48KB data lock 0B index-container-roots 102B src log4j.properties 279B applicationContext.xml 2KB activemq demo Book.java 725B Run.java 795B DefaultMessageConverter.java 2KB ResourceMessageConverter.java 1KB ResourceMessageProducer.java 926B ResourceMessageConsumer.java 542B .springBeans 424B .classpath 764B lib 
评论15