WEB-INF/classes/example/SimpleMessageBean.java
package example; import java.util.logging.Level; import java.util.logging.Logger; import javax.ejb.EJBException; import javax.ejb.MessageDrivenBean; import javax.ejb.MessageDrivenContext; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; public class SimpleMessageBean implements MessageDrivenBean, MessageListener { static protected final Logger log = Logger.getLogger(SimpleMessageBean.class.getName()); public void ejbCreate() throws EJBException { log.fine("ejbCreate()"); } public void setMessageDrivenContext(MessageDrivenContext cxt) throws EJBException { log.fine("setMessageDrivenContext()"); } public void onMessage(Message msg) { // process the message String text = null; if (msg instanceof TextMessage) { try { text = ((TextMessage) msg).getText(); } catch (Exception ex) { log.log(Level.WARNING,null,ex); } } else { text = msg.toString(); } log.info("onMessage(): " + text); } public void ejbRemove() throws EJBException { log.fine("ejbRemove()"); } }