messageprinterbean.java

J2EE开发与Weblogic一书中的源代码

package com.learnweblogic.examples.ch10.textmessage;

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 MessagePrinterBean 
  implements MessageDrivenBean, MessageListener
{
  private MessageDrivenContext ctx;

  public void setMessageDrivenContext(MessageDrivenContext c) {
    ctx = c;
  }

  public void ejbCreate() {}
  public void 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();
    }
  }
}