logbean.java

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

package examples;

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

public class LogBean implements MessageDrivenBean, MessageListener {

 protected MessageDrivenContext ctx;
 public TemporaryQueue queue;

 public void setMessageDrivenContext(MessageDrivenContext ctx) {
  this.ctx = ctx;
 }

 public void ejbCreate() {
  System.err.println("ejbCreate()");
 }

 public void onMessage(Message msg) {
  System.err.println("onMessage()");
  TextMessage tm = (TextMessage) msg;   
  try {
   String text = tm.getText(); 
   System.err.println("Received new message : " + text);
   onReturn(text);
  }
  catch(JMSException e) {
   e.printStackTrace();
  }
 }
 
 public void onReturn(String str){
     try{ 
          System.err.println("onReturn()");
          InitialContext ctxt=new InitialContext();
    	  TopicConnectionFactory factory =  (TopicConnectionFactory) ctxt.lookup("jms/TopicConnectionFactory");

    	  TopicConnection connection = factory.createTopicConnection();
    	  
    	  TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); 

    	  Topic topic = (Topic) ctxt.lookup("jms/Topic");

    	  TopicPublisher publisher = session.createPublisher(topic);

    	  TextMessage msg = session.createTextMessage();

    	  msg.setText(str); 

    	  publisher.publish(msg);          

      }catch(Exception e){
      	System.out.print("there is a exception");
      	
      }
 }
 
 public void ejbRemove() {
  System.err.println("ejbRemove()");
 }
}