KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > jfox > test > ejb3 > mdb > MessageSenderBean


1 /*
2  * JFox - The most lightweight Java EE Application Server!
3  * more details please visit http://www.huihoo.org/jfox or http://www.jfox.org.cn.
4  *
5  * JFox is licenced and re-distributable under GNU LGPL.
6  */
7 package jfox.test.ejb3.mdb;
8
9 import javax.annotation.Resource;
10 import javax.ejb.EJBException JavaDoc;
11 import javax.ejb.Remote JavaDoc;
12 import javax.ejb.Stateless JavaDoc;
13 import javax.jms.Message JavaDoc;
14 import javax.jms.QueueConnection JavaDoc;
15 import javax.jms.QueueConnectionFactory JavaDoc;
16 import javax.jms.QueueSender JavaDoc;
17 import javax.jms.QueueSession JavaDoc;
18 import javax.jms.Session JavaDoc;
19 import javax.jms.TopicConnection JavaDoc;
20 import javax.jms.TopicConnectionFactory JavaDoc;
21 import javax.jms.TopicPublisher JavaDoc;
22 import javax.jms.TopicSession JavaDoc;
23
24 import org.jfox.ejb3.naming.JNDIContextHelper;
25
26 /**
27  * @author <a HREF="mailto:jfox.young@gmail.com">Young Yang</a>
28  */
29 @Stateless JavaDoc
30 @Remote JavaDoc
31 public class MessageSenderBean implements MessageSender {
32
33     @Resource
34     QueueConnectionFactory JavaDoc queueConnectionFactory;
35
36     public void sendQueueMessage(Message JavaDoc message) {
37         try {
38             // use injected jms connection factory
39 QueueConnection JavaDoc qc = queueConnectionFactory.createQueueConnection();
40             QueueSession JavaDoc qs = qc.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
41             QueueSender JavaDoc sender = qs.createSender(qs.createQueue("testQ"));
42             sender.send(qs.createTextMessage("Hello, Queue MDB!"));
43         }
44         catch (Exception JavaDoc e) {
45             throw new EJBException JavaDoc(e);
46         }
47     }
48
49     public void sendTopicMessage(Message JavaDoc message) {
50         try {
51             // lookup jms connection factory by jndi
52 TopicConnectionFactory JavaDoc tcf = (TopicConnectionFactory JavaDoc)JNDIContextHelper.lookup("defaultcf");
53             TopicConnection JavaDoc tc = tcf.createTopicConnection();
54             TopicSession JavaDoc ts = tc.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
55             TopicPublisher JavaDoc tp = ts.createPublisher(ts.createTopic("testT"));
56             tp.send(ts.createTextMessage("Hello, Topic MDB!"));
57         }
58         catch (Exception JavaDoc e) {
59             throw new EJBException JavaDoc(e);
60         }
61     }
62
63 }
64
Popular Tags