logbean.java

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

package examples;

import javax.ejb.*;
import javax.jms.*;

public class LogBean implements MessageDrivenBean, MessageListener {

protected MessageDrivenContext ctx;

public void setMessageDrivenContext(MessageDrivenContext ctx) {
  System.out.println("setMessageDrivenContext()");
  this.ctx = ctx;
}

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

public void onMessage(Message msg) {



  try {
    if (msg instanceof BytesMessage) {
       BytesMessage bm = (BytesMessage) msg;
       byte[] value = new byte[(int) bm.getBodyLength()];
       bm.readBytes(value);
       System.err.println("Received new message:### "+value[0]+" "+value[(int)bm.getBodyLength() -1]);
    } else if (msg instanceof ObjectMessage){
       ObjectMessage om = (ObjectMessage) msg;
       System.err.println("Received new message:### " + " Object Message");
    } else if (msg instanceof StreamMessage) {
       StreamMessage sm = (StreamMessage) msg;
       System.err.println("Received new message:### " + " Stream Message");
    } else if (msg instanceof MapMessage) {
       MapMessage mm = (MapMessage) msg;
       System.err.println("Received new message:### " + " Map Message");
    } else if (msg instanceof TextMessage){
       TextMessage tm = (TextMessage) msg;
       String text = tm.getText();
       System.err.println("Received new message:### " + text);
    } else
       throw new JMSException("JMS message sending errors.");
  } catch(JMSException e) {
     e.printStackTrace();
  }
}

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