//消息客戶端程序
package examples.Message;
import javax.jms.*;
import javax.naming.*;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class MessageClient {
    public static void main(String[] args) {
        Context                 jndiContext = null;
        QueueConnectionFactory  queueConnectionFactory = null;
        QueueConnection         queueConnection = null;
        QueueSession            queueSession = null;
        Queue                   queue = null;
        QueueSender             queueSender = null;
        MapMessage             message = null;
        final int               NUM_MSGS;
        //獲取JNDI上下文，同時查看連接factory和隊列		
        try {
            jndiContext = new InitialContext();
			Object tmp = jndiContext.lookup("ConnectionFactory");
			queueConnectionFactory = (QueueConnectionFactory) tmp;			
			jndiContext.lookup("java:comp/env/QueueConnectionFactory");	
			queue = (Queue) jndiContext.lookup("queue/A");			
        } catch (NamingException e) {			
            System.out.println("JNDI lookup failed: " + e.toString());
            System.exit(1);
        }
        //通過連接創建會話。創建發送者和映射消息。
		//發送消息，同時對文本進行少量修改
		//發送end-of-messages消息，最后關閉連接		
        try {
          //創建連接
          queueConnection = queueConnectionFactory.createQueueConnection();	  
          //通過連接創建會話
          queueSession =queueConnection.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
		  queueConnection.start(); 
          //創建發送者
          queueSender = queueSession.createSender(queue);
          //創建Map映射消息
          message = queueSession.createMapMessage(); 
          //定義一些Name/Value對
          message.setString ("OrderID", "1"); 
          message.setInt ("ItemID", 5);	 
          message.setInt ("Quantity", 50); 
          message.setDouble ("UnitPrice", 5.00); 
          message.setString ("emailID", "jwu@webjet.com.cn");	  
          //發送消息
          queueSender.send (message);		  
        } catch (JMSException e) {
          System.out.println("Exception occurred: " + e.toString());
        }
        finally {
          if (queueConnection != null) {
            try {
              queueConnection.close();
            } catch (JMSException e) {}
          }
        }
    }
}