1 22 package org.jboss.ejb3.test.jca.inflowmdb; 23 24 import org.jboss.logging.Logger; 25 import org.jboss.annotation.ejb.ResourceAdapter; 26 27 import javax.ejb.MessageDriven ; 28 import javax.ejb.ActivationConfigProperty ; 29 import javax.jms.Message ; 30 import javax.jms.MessageListener ; 31 32 37 @MessageDriven (activationConfig = 38 { 39 @ActivationConfigProperty (propertyName="destinationType", propertyValue="javax.jms.Queue"), 40 @ActivationConfigProperty (propertyName="destination", propertyValue="queue/inflowmdbtest"), 41 @ActivationConfigProperty (propertyName="maxSession", propertyValue="1") 42 }) 43 @ResourceAdapter("jms-ra.rar") 44 public class JMSMDBBean implements MessageListener 45 { 46 private static final Logger log = Logger.getLogger(JMSMDBBean.class); 47 48 public static boolean called = false; 49 50 public void onMessage(Message recvMsg) 51 { 52 log.info("************** here!!!!"); 53 called = true; 54 } 55 } 56 | Popular Tags |