messagebean.java

java的一系列产品中包括jsme,jmse,j2ee,本文件提供j2ee实现的源代码.

package jmsejb;

import java.util.Properties;
import javax.rmi.PortableRemoteObject;
import javax.naming.InitialContext;
import javax.naming.Context;
import javax.naming.NamingException;

import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class MessageBean implements MessageDrivenBean,MessageListener
{
  private static MessageDrivenContext ctx;  
  public void setMessageDrivenContext(MessageDrivenContext c) {
    ctx = c;
  }

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

  public void onMessage(Message m) {
    TextMessage msg = (TextMessage) m;
    try {
      System.err.println("Message-Driven EJB received message: "+
        msg.getText());
    } catch (JMSException e) {
      System.err.println("Exception receiving text from message: ");
      e.printStackTrace();
    }
  }  
}