/* * To change this template, choose Tools | Templates * and open the template in the editor. */ package lrp.queue.test; import javax.annotation.Resource; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; import javax.ejb.MessageDrivenContext; import javax.ejb.TransactionManagement; import javax.ejb.TransactionManagementType; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.ObjectMessage; import org.jboss.annotation.ejb.ResourceAdapter; @MessageDriven(name = "dumQueue", activationConfig = { @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"), @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/dumQueue"), @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge")}, messageListenerInterface = MessageListener.class) @ResourceAdapter("hornetq-ra.rar") @TransactionManagement(TransactionManagementType.CONTAINER) public class dumMDB implements MessageListener { @Resource MessageDrivenContext ctx; public dumMDB() { } public void onMessage(Message message) { try { System.out.println("Message :" + message); ObjectMessage tmsg = null; tmsg = (ObjectMessage) message; System.out.println("Consuming Message = "); } catch (Exception ex) { ex.printStackTrace(); } } }