1 22 package org.jboss.ejb3.test.jca.inflowmdb; 23 24 import javax.ejb.ActivationConfigProperty ; 25 import javax.ejb.MessageDriven ; 26 import javax.ejb.TransactionAttribute ; 27 import javax.ejb.TransactionAttributeType ; 28 29 import org.jboss.ejb3.mdb.inflow.MessageInflowLocalProxy; 30 import org.jboss.ejb3.test.jca.inflow.TestMessage; 31 import org.jboss.ejb3.test.jca.inflow.TestMessageListener; 32 import org.jboss.logging.Logger; 33 import org.jboss.annotation.ejb.ResourceAdapter; 34 35 40 @MessageDriven (name = "TestMDB", activationConfig = 41 { 42 @ActivationConfigProperty (propertyName="name", propertyValue="testInflow"), 43 @ActivationConfigProperty (propertyName="anInt", propertyValue="5"), 44 @ActivationConfigProperty (propertyName="anInteger", propertyValue="55"), 45 @ActivationConfigProperty (propertyName="localhost", propertyValue="127.0.0.1"), 46 @ActivationConfigProperty (propertyName="props", propertyValue="key1=value1,key2=value2,key3=value3") 47 }) 48 @ResourceAdapter("jcainflow.rar") 49 @TransactionAttribute (TransactionAttributeType.REQUIRED) 50 public class TestMDBMessageListener implements TestMessageListener 51 { 52 private static final Logger log = Logger.getLogger(TestMDBMessageListener.class); 53 54 public void deliverMessage(TestMessage message) 55 { 56 message.acknowledge(); 57 log.info(message.toString()); 58 } 59 } 60 | Popular Tags |