KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > jboss > tutorial > consumer > bean > TesterBean


1 /*
2  * JBoss, the OpenSource J2EE webOS
3  *
4  * Distributable under LGPL license.
5  * See terms of license at gnu.org.
6  */

7 package org.jboss.tutorial.consumer.bean;
8
9 import java.util.HashMap JavaDoc;
10 import java.util.Map JavaDoc;
11 import org.jboss.annotation.JndiInject;
12 import javax.ejb.Remote JavaDoc;
13 import javax.ejb.Stateless JavaDoc;
14 import javax.ejb.TransactionAttribute JavaDoc;
15 import javax.ejb.TransactionAttributeType JavaDoc;
16 import org.jboss.ejb3.mdb.ProducerManager;
17 import org.jboss.ejb3.mdb.ProducerObject;
18
19 /**
20  * Show injecting in producers
21  * Show how to interact with local producers
22  *
23  * @author <a HREF="mailto:bill@jboss.org">Bill Burke</a>
24  * @version $Revision: 1.3.2.3 $
25  */

26 @Stateless JavaDoc
27 @Remote JavaDoc(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 JavaDoc(TransactionAttributeType.REQUIRED)
51    public void testXA() throws Exception JavaDoc
52    {
53
54       xaManager.connect();
55       xa.method1("testXA", 1);
56       Map JavaDoc<String JavaDoc, String JavaDoc> map = new HashMap JavaDoc<String JavaDoc, String JavaDoc>();
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 JavaDoc
65    {
66
67       localManager.connect();
68       local.method1("testLocal", 1);
69       Map JavaDoc<String JavaDoc, String JavaDoc> map = new HashMap JavaDoc<String JavaDoc, String JavaDoc>();
70       map.put("hello", "world");
71       map.put("great", "ejb3");
72       local.method2("testLocal2", map);
73       localManager.close();
74    }
75
76 }
77
Popular Tags