import javax.jms.TextMessage;
import javax.jms.JMSException;

import net.jxta.endpoint.Message;
import net.jxta.endpoint.StringMessageElement;


public class JMSToJXTAMsgConverter
{
    private Message jxtaMessage = null;

    public JMSToJXTAMsgConverter ( String sender, 
                                   TextMessage jmsMsg
                                 ) throws JMSException {
        StringMessageElement smeSender  = null;
        StringMessageElement smeMessage = null;

        jxtaMessage = new net.jxta.endpoint.Message ();
        smeSender  = new StringMessageElement ("JMSSender", sender, null);
        smeMessage = new StringMessageElement ("Message", jmsMsg.getText(), null);

        jxtaMessage.addMessageElement (smeSender);
        jxtaMessage.addMessageElement (smeMessage);
    }//JMSToJXTAMsgConverter constructor

    public Message getMessage () {
        return jxtaMessage;
    }//getMessage()
}