KickJava   Java API By Example, From Geeks To Geeks.

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


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 java.util.Hashtable JavaDoc;
10 import javax.naming.Context JavaDoc;
11 import javax.naming.InitialContext JavaDoc;
12 import javax.jms.QueueConnectionFactory JavaDoc;
13 import javax.jms.QueueConnection JavaDoc;
14 import javax.jms.QueueSession JavaDoc;
15 import javax.jms.Session JavaDoc;
16 import javax.jms.Queue JavaDoc;
17 import javax.jms.QueueSender JavaDoc;
18
19 import org.jfox.framework.Framework;
20 import org.jfox.ejb3.naming.InitialContextFactoryImpl;
21 import org.jfox.ejb3.naming.url.javaURLContextFactory;
22
23 /**
24  * @author <a HREF="mailto:jfox.young@gmail.com">Young Yang</a>
25  */
26 public class MDBClient {
27
28     public static void main(String JavaDoc[] args) throws Exception JavaDoc {
29         // start Framework
30 Framework framework = new Framework();
31         framework.start();
32
33         // initialize JNDI
34 Hashtable JavaDoc<String JavaDoc, String JavaDoc> prop = new Hashtable JavaDoc<String JavaDoc, String JavaDoc>();
35         prop.put(Context.INITIAL_CONTEXT_FACTORY, InitialContextFactoryImpl.class.getName());
36         prop.put(Context.OBJECT_FACTORIES, InitialContextFactoryImpl.class.getName());
37         prop.put(Context.URL_PKG_PREFIXES, javaURLContextFactory.class.getPackage().getName());
38         prop.put(Context.PROVIDER_URL, "java://localhost");
39         Context JavaDoc context = new InitialContext JavaDoc(prop);
40         QueueConnectionFactory JavaDoc connectionFactory = (QueueConnectionFactory JavaDoc)context.lookup("defaultcf");
41         QueueConnection JavaDoc connection = connectionFactory.createQueueConnection();
42         QueueSession JavaDoc session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
43         Queue JavaDoc queue = session.createQueue("testQ");
44         QueueSender JavaDoc sender = session.createSender(queue);
45         sender.send(session.createTextMessage("Hello, JMS! " + System.currentTimeMillis()));
46         session.close();
47         connection.close();
48
49         // stop Framework
50 Thread.sleep(2000);
51         framework.stop();
52     }
53 }
54
Popular Tags