logbeanclient.java

EJB实践的服务器是用SUN的服务器

package examples;

import javax.naming.*;

import javax.jms.*;
import java.util.Properties;

public class LogBeanClient {

    public static void main (String[] args) throws Exception {
	 TextMessage msg;
	 QueueSender sender;
	 QueueConnectionFactory factory;
	 QueueConnection connection;
	 QueueSession sessionMe;
	 Queue queue;
	try
	{
	  Properties env = new Properties();
	  env.put("java.naming.factory.initial","com.sun.enterprise.naming.SerialInitContextFactory");
	  env.put("java.naming.provider.url", "iiop://localhost:3700");
	  InitialContext ctxt = new InitialContext(env);
	  factory =  (QueueConnectionFactory) ctxt.lookup("jms/QueueConnectionFactory");
	  connection = factory.createQueueConnection();
	  sessionMe = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); 
	  queue = (Queue) ctxt.lookup("jms/Queue");
	  sender = sessionMe.createSender(queue);
	  msg = sessionMe.createTextMessage();
	  msg.setText("love");   
	  TemporaryQueue tempQueue = (TemporaryQueue)sessionMe.createTemporaryQueue(); 
	  msg.setJMSReplyTo(tempQueue);
	  QueueReceiver queueReceiver =sessionMe.createReceiver(tempQueue);
	  sender.send(msg);
	  
	  connection.start();
	  Message message = queueReceiver.receive();
	  String messageText = null;
	  if(message instanceof TextMessage){
	      messageText = ((TextMessage) message).getText();
	      System.out.print("服务器收到返回消息：");
	      System.out.print(messageText);        
	  }else{
	      System.out.print("服务器没有返回消息。");
	  }//else
	}//try
	catch(Exception ne)
	{
	 ne.printStackTrace();
	}//catch
	System.exit(0);
   }
 }