import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; import org.apache.log4j.Logger; @MessageDriven(activationConfig = { @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"), @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue") }, mappedName = "ejb/MyMDB") public class MyMDB implements MessageListener { final static Logger logger = Logger.getLogger(MyMDB.class); public void onMessage(Message paramMessage) { TextMessage tm = (TextMessage)paramMessage; try { String text = tm.getText(); logger.info("received JMS message" + text); } catch (JMSException e) { logger.error("unable to read jms message", e); } } }
Wednesday, March 16, 2011
Minimalistic MDB on JBoss
http://docs.jboss.org/ejb3/docs/tutorial/1.0.7/html/Message_Driven_Beans.html
Subscribe to:
Post Comments (Atom)
No comments:
Post a Comment