package mdb;
//聲明本類引入的其它類
import java.rmi.RemoteException;
import java.util.Properties;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;



import javax.ejb.CreateException;
import javax.ejb.RemoveException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.rmi.PortableRemoteObject;

/**
 * 這個類演示調用一個消息驅動的bean并在主題消息中發布報價。
 *
 */

public class Client {
  static private String TOPIC_NAME = "myQQ";
  //聲明服務器url
  private String m_url;
  //聲明上下文
  private Context m_context;
  //聲明主題連接
  private TopicConnection m_topicConnection;
  //構造方法
  public Client(String url)
    throws NamingException
  {
    m_url = url;
        
    try {
      // 創建上下文
      m_context = getInitialContext();
      // 創建連接并啟動
      TopicConnectionFactory cf =
        (TopicConnectionFactory) m_context.lookup("weblogic.jms.ConnectionFactory");
      m_topicConnection = cf.createTopicConnection();
      m_topicConnection.start();
      
    }
    catch(Exception ex) {
      ex.printStackTrace();
    }
  }


  /**
   * 用命令行運行本實例:
    */
  public static void main(String[] args) throws Exception {
    String url  = "t3://localhost:7001";
    
    // 解析命令行參數
     if (args.length == 1) {
          url = args[0];
    }

    Client client = null;
    try {
    //本類實例
      client = new Client(url);
    } catch (NamingException ne) {
      System.exit(1);
    }

    try {
    //調用例程
      client.send();
    }
    catch (Exception e) {
    //異常處理
      System.out.println(e);
    } 
  }

  /**
   * 發送消息
   */
  public void send()
    throws RemoteException, JMSException, NamingException
  {
  //聲明主題	
    Topic newTopic = null;
    //聲明主題會話
    TopicSession session = null;
    try {
    //創建主題會話	
      session =
        m_topicConnection.createTopicSession(false,   // non transacted
                                             Session.AUTO_ACKNOWLEDGE);
      //查找主題
      newTopic = (Topic) m_context.lookup(TOPIC_NAME);
    }
    catch(NamingException ex) {
    //異常處理
      newTopic = session.createTopic(TOPIC_NAME);
      m_context.bind(TOPIC_NAME, newTopic);
    }
    //創建消息發布
    TopicPublisher sender = session.createPublisher(newTopic);
    //創建文本消息
    TextMessage tm = session.createTextMessage();
    String[] quotes = new String[] {
      "CPU AMD $350", "HD IBM $680", "CD-ROM acr52X $220"
    };
    for (int i = 0; i < quotes.length; i++) {
    //發送消息
      tm.setText(quotes[i]);
      sender.publish(tm);
    }
  }


  /**
   * 初始化上下文
   */
  private Context getInitialContext() throws NamingException {
    
    try {
      // 屬性對象
      Properties p = new Properties();
      p.put(Context.INITIAL_CONTEXT_FACTORY,
        "weblogic.jndi.WLInitialContextFactory");
      p.put(Context.PROVIDER_URL, m_url);
      return new InitialContext(p);
    }
    catch (NamingException e) {
      log("can't get a connection to the WebLogic server at "+m_url);
      throw e;
    }
  }

  private static void log(String s) {
    System.out.println(s);
  }
  
}