personconverter.java

《精通Spring》源代码

/*
 * Created on 2005-2-11
 * 
 * http://www.open-v.com 提供代码的维护工作
 */
package com.openv.spring;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.jms.support.converter.MessageConversionException;
import org.springframework.jms.support.converter.MessageConverter;

/**
 * 自定义MessageConverter实现
 * 
 * @author luoshifei
 */
public class PersonConverter implements MessageConverter {

    public Message toMessage(Object object, Session session)
            throws JMSException, MessageConversionException {
        PersonVO personVO = (PersonVO) object;
        MapMessage mm = session.createMapMessage();
        mm.setString("firstname", personVO.getFirstname());
        mm.setString("lastname", personVO.getLastname());
        return mm;
    }

    public Object fromMessage(Message message) throws JMSException,
            MessageConversionException {
        if (!(message instanceof MapMessage))
            return null;

        MapMessage mm = (MapMessage) message;
        PersonVO personVO = new PersonVO();
        try {
            personVO.setFirstname(mm.getString("firstname"));
            personVO.setLastname(mm.getString("lastname"));
        } catch (JMSException jmse) {
            throw new MessageConversionException(jmse.getMessage());
        }
        return personVO;
    }

}