1 7 package org.jboss.tutorial.consumer.bean; 8 9 import java.util.HashMap ; 10 import java.util.Map ; 11 import org.jboss.annotation.JndiInject; 12 import javax.ejb.Remote ; 13 import javax.ejb.Stateless ; 14 import javax.ejb.TransactionAttribute ; 15 import javax.ejb.TransactionAttributeType ; 16 import org.jboss.ejb3.mdb.ProducerManager; 17 import org.jboss.ejb3.mdb.ProducerObject; 18 19 26 @Stateless 27 @Remote (Tester.class) 28 public class TesterBean implements Tester 29 { 30 private ExampleProducerXA xa; 31 private ProducerManager xaManager; 32 33 @JndiInject(jndiName="org.jboss.tutorial.consumer.bean.ExampleProducerXA") 34 public void setXa(ExampleProducerXA xa) 35 { 36 this.xa = xa; 37 this.xaManager = ((ProducerObject)xa).getProducerManager(); 38 } 39 40 private ExampleProducer local; 41 private ProducerManager localManager; 42 43 @JndiInject(jndiName="org.jboss.tutorial.consumer.bean.ExampleProducerLocal") 44 public void setLocal(ExampleProducer local) 45 { 46 this.local = local; 47 this.localManager = ((ProducerObject)local).getProducerManager(); 48 } 49 50 @TransactionAttribute (TransactionAttributeType.REQUIRED) 51 public void testXA() throws Exception 52 { 53 54 xaManager.connect(); 55 xa.method1("testXA", 1); 56 Map <String , String > map = new HashMap <String , String >(); 57 map.put("hello", "world"); 58 map.put("great", "ejb3"); 59 xa.method2("testXA2", map); 60 System.out.println("end TESTXA **"); 61 xaManager.close(); 62 } 63 64 public void testLocal() throws Exception 65 { 66 67 localManager.connect(); 68 local.method1("testLocal", 1); 69 Map <String , String > map = new HashMap <String , String >(); 70 map.put("hello", "world"); 71 map.put("great", "ejb3"); 72 local.method2("testLocal2", map); 73 localManager.close(); 74 } 75 76 } 77 | Popular Tags |