jmssearch.java

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

import javax.jms.Queue;
import javax.jms.QueueSender;
import javax.jms.QueueSession;

import javax.naming.Context;
import javax.naming.InitialContext;


public class JMSSearch
{
   
    public JMSSearch ()    {
    }

    public QueueSender getQueueSender ( String queueName, 
                                       QueueSession queueSession ) {
        InitialContext jndiContxt = null;
        Queue outgoingQueue= null;
        QueueSender qSender = null;
 
        try
        {
            jndiContxt = new InitialContext ();
            outgoingQueue= (Queue) jndiContxt.lookup ( queueName );
            System.out.println ("JMSSearch >> OutgoingQueue found.");

            qSender = queueSession.createSender (outgoingQueue);
        }
        catch ( Exception e ) 
        {
            e.printStackTrace ();
        }
        return qSender;
    }//getQueueSender()
}