logbeanclient.java

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

package examples;

import javax.naming.*;
import javax.jms.*;
import java.util.*;
import javax.ejb.*;
import java.io.*;

public class LogBeanClient implements javax.jms.MessageListener
{
	InitialContext jndiContext=null;
	TopicConnectionFactory factory =null;
	TopicConnection connect=null;
	TopicSession session=null;
	TopicSession session1=null;
	TopicSubscriber subscriber=null;
	TopicPublisher publisher=null; 
	Topic topic=null;
	Topic topic1=null;
	

	public static void main(String [] args) throws Exception 
	{
		
	   LogBeanClient log=new LogBeanClient();
		

	   
		
	} 
	

	public LogBeanClient() throws Exception 
	{
	     
	    getInitialContext(); 
		factory = (TopicConnectionFactory) 
		jndiContext.lookup("jms/TopicConnectionFactory"); 
		
	    topic = (Topic)jndiContext.lookup("jms/Topic"); 
		topic1 = (Topic)jndiContext.lookup("jms/Topic");
		connect = factory.createTopicConnection(); 
		
		//TopicSession session = connect.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
		session = connect.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
		session1 = connect.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
		
			   sendMessage();
		
		subscriber = session1.createSubscriber(topic1); 
		subscriber.setMessageListener(this); 
		connect.start(); 
		System.out.println(" Client is listening a message!");
		System.err.println("----------------------------------------------------");
		
	} 
	
	
	public void onMessage(Message msg)
	 {
	 	
	 try
	 {
	   if (msg instanceof TextMessage)
	   {
       TextMessage tm = (TextMessage) msg;
       String text = tm.getText();
       System.err.println("Received new message:### " + text);
       System.err.println("----------------------------------------------------");
       } 
      else
    
        throw new JMSException("JMS message sending errors.");
    } 
    catch(JMSException e) 
    {
     e.printStackTrace();
     }
	 	 
	 	 
	 } 
	 
	 
	 public  void sendMessage()throws Exception 
	 {
	   
	 	
	 	topic = (Topic) jndiContext.lookup("jms/Topic");
	 	
	 	publisher = session.createPublisher(topic);
	 	
  TextMessage textMsg = session.createTextMessage();
  textMsg.setText("This is a test message.");
  textMsg.setStringProperty("logLevel","severe");
  textMsg.setStringProperty("name","wu");
  publisher.publish(textMsg);
  System.out.println(" Client has sent a text message!");
  Thread.sleep(3000);

    TextMessage textMsg2 = session.createTextMessage();
  textMsg2.setText("This is a test message 2.");
  textMsg2.setStringProperty("logLevel","severe");
  textMsg2.setStringProperty("name","wu");
  publisher.publish(textMsg2);
  System.out.println(" Client has sent a text message!");
  Thread.sleep(3000);  

  TextMessage textMsg1 = session.createTextMessage();
  textMsg1.setText("This is a test message not dealed with by LogBean.");
    textMsg1.setStringProperty("logLevel","seveddfre");
  textMsg1.setStringProperty("name","wfdfu");
  publisher.publish(textMsg1);
  System.out.println(" Client has sent a text message!");
  Thread.sleep(3000);
  
  

	 }
	 
	 
	 public void  getInitialContext()throws Exception 
	 {
	 	Properties env = new Properties();
	 	env.put("java.naming.factory.initial","com.sun.enterprise.naming.SerialInitContextFactory");
	 	env.put("java.naming.provider.url", "iiop://localhost:3700");
	 	jndiContext = new InitialContext(env);
	 	
     } 
}