jxta4jmsmessage.java

p2p 是现在java社区最火的一个话题, 看看jxta能给P2p带来什么吧

import net.jxta.j2me.Message;
import net.jxta.j2me.Element;


public class JXTA4JMSMessage
{
    private Message message = null;
    private String sender = null;
    private String recipient = null;
    private String messageText = null;    
    
    
    public JXTA4JMSMessage (Message msg) {
        processMessage(msg);
    }//JXTA4JMSMessage
        
    public JXTA4JMSMessage (String recipient, String messageText)
    {
       Element[] msgElements = new Element [2];
       this.recipient = recipient;
       this.messageText = messageText;

       msgElements[0] = new Element ( 
                                     "JMSRecipient",
                                     (recipient).getBytes(),
                                     null,
                                     null
                                    );

       msgElements[1] = new Element ( 
                                     "Message", 
                                     messageText.getBytes(), 
                                     null, 
                                     null 
                                     );
                                      
       message = new Message ( msgElements );
    }//JXTA4JMSMessage


    private void processMessage (Message msg) {
        try {
            for (int j=0; j < msg.getElementCount(); j++) {
                Element e = msg.getElement(j);
                if ((e.getName()).equals("JMSSender"))
                    sender = new String(e.getData());
                else if ((e.getName()).equals("Message"))
                    messageText = new String (e.getData());
                
            }//for (int j=0;) 

            if (sender != null) {
                System.out.println (">>> JMSMessage...received message from "+ sender);
                Element[] msgElements = new Element [2];
                msgElements[0] = new Element ( 
                                              "JMSSender",
                                              (sender).getBytes(),
                                              null,
                                              null 
                                             );

                msgElements[1] = new Element ( 
                                              "Message", 
                                              messageText.getBytes(), 
                                              null, 
                                              null 
                                             );
                          
                message = new Message ( msgElements );    
           }//if (sender!=null)

        }//try
        catch(NumberFormatException ne){
            ne.printStackTrace();
        }//catch
 
    }//processMessage()


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

    public String getSender(){
        return sender;
    }//getSender()
    
    public String getRecipient(){
        return recipient;
    }//getRecipient()

    public String getMessageText() {
        return messageText;
    }//getMessageText() 
   
}