import net.jxta.endpoint.Message;
import net.jxta.endpoint.MessageElement;

import javax.jms.Session;
import javax.jms.QueueSession;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.JMSException;



public class JXTAToJMSMsgConverter
{
    private String jmsRecipient;
    private javax.jms.TextMessage jmsMessage = null;
    private QueueSession queueSession = null;


    public JXTAToJMSMsgConverter (
                              QueueConnectionFactory qConnFactory, 
                              net.jxta.endpoint.Message jxtaMsg
                            ) throws JMSException {
          QueueConnection queueConnection = null;
  
          try
          {
              //Creating a new JMS text message.
              //Step 1:
              queueConnection = qConnFactory.createQueueConnection ();
              //Step 2:              
              queueSession = queueConnection.createQueueSession (false, Session.AUTO_ACKNOWLEDGE);
              //Step 3:
              jmsMessage = queueSession.createTextMessage ();              
          }
          catch ( Exception e ) 
          {
              e.printStackTrace ();
          }

        MessageElement jmsRecipientElement, msgElement;
        jmsRecipientElement = jxtaMsg.getMessageElement ("JMSRecipient");
        msgElement = jxtaMsg.getMessageElement ("Message");

        jmsRecipient = jmsRecipientElement.toString();
        jmsMessage.setText (msgElement.toString());
        System.out.println ( "JXTA4JMS>>> The jmsRecipient is: " + jmsRecipient );
        
    }//JXTAToJMSMsgConverter


    public QueueSession getQueueSession() {
        return queueSession;
    }//getQueueSession()
    
    public javax.jms.TextMessage getMessage() {
        return jmsMessage;
    }//getMessage()

    public String getJMSRecipient() {
        return "jms/" + jmsRecipient;
    }//getJMSRecipient()

}