import javax.jms.Message;

import javax.jms.TextMessage;

import javax.jms.TopicConnectionFactory;

import javax.jms.TopicConnection;

import javax.jms.Topicsession;

import javax.jms.Topic;

import javax.jms.Session;

import javax.jms.TopicSubscriber;

import javax.jms.JMSException;

import javax.naming.InitialContext;

 

 

public class JmsClient_1 implements javax.jms.MessageListener {

 

    public static void main(String［］args) throws Exception {

        

        if(args.length != 2)

            throw new Exception("Wrong number of arguments");

        

        new JmsClient_1(args［0］, args［1］);

        

        while(true){Thread.sleep(10000);}

        

    }

        

    public JmsClient_1(String factoryName, String topicName) throws Exception {

            

        InitialContext jndiContext = getInitialContext();

        

        TopicConnectionFactory factory = (TopicConnectionFactory)

            jndiContext.lookup("TopicFactoryNameGoesHere");

        

        Topic topic = (Topic)jndiContext.lookup("TopicNameGoesHere");

 

        TopicConnection connect = factory.createTopicConnection();

 

        TopicSession session = 

            connect.createTopicSession(false,Session.AUTO_ACKNOWLEDGE); 

 

        TopicSubscriber subscriber = session.createSubscriber(topic);

 

        subscriber.setMessageListener(this);

        

        connect.start();

    }

    

    public void onMessage(Message message) {

        try {

        

            TextMessage textMsg = (TextMessage)message;

            String text = textMsg.getText();

            System.out.println("/n RESERVATION RECIEVED:/n"+text);

        

        } catch(JMSException jmsE) {

            jmsE.printStackTrace();

        }

    }

    

    public static InitialContext getInitialContext() {

        // 創(chuàng)建具體產(chǎn)品廠商的JNDI上下文

    }

}

public static InitialContext getInitialContext() {

    Properties env = new Properties();

    env.put(Context.SECURITY_PRINCIPAL, "guest");

    env.put(Context.SECURITY_CREDENTIALS, "guest");

    env.put(Context.INITIAL_CONTEXT_FACTORY,

       "weblogic.jndi.WLInitialContextFactory");

    env.put(Context.PROVIDER_URL, "t3://localhost:7001");

    return new InitialContext(env);

}

TopicSession session = 

    connect.createTopicSession(false,Session.AUTO_ACKNOWLEDGE); 

 

TopicSubscriber subscriber = session.createSubscriber(topic);

 

subscriber.setMessageListener(this);

        

connect.start();

public void onMessage(Message message) {

    try {

        TextMessage textMsg = (TextMessage)message;

        String text = textMsg.getText();

        System.out.println("/n RESERVATION RECIEVED:/n"+text);

        

    } catch(JMSException jmsE) {

        jmsE.printStackTrace();

    }

}