开发工具:
文件大小: 26kb
下载次数: 0
上传时间: 2010-03-12
详细说明： 例子： import java.util.Hashtable; import javax.jms.*; import javax.naming.*; import javax.naming.directory.*; public class sample { protected QueueConnectionFactory factory = null; protected QueueConnection connection; protected QueueSession queueSession; protected TextMessage outMessage; protected QueueSender queueSender; protected QueueReceiver queueReceiver; public static final String qcfLookup = "EXAMPLEQCF"; public static final String qLookup = "EXAMPLEQL"; public stat ic final String icf = "com.sun.jndi.fscontext.RefFSContextFactory"; public String url = "file:/d:/temp"; public void sampleInit() throws Exception { Hashtable environment = new Hashtable(); environment.put(Context.INITIAL_CONTEXT_FACTORY, icf); environment.put(Context.PROVIDER_URL, url); environment.put(Context.REFERRAL, "throw"); Context ctx = new InitialDirContext(environment); factory = (QueueConnectionFactory) ctx.lookup(qcfLookup); Queue q1 = null; q1 = (Queue) ctx.lookup(qLookup); connection = factory.createQueueConnection(); queueSession = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); queueSender = queueSession.createSender(q1); queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT); outMessage = queueSession.createTextMessage(); queueReceiver = queueSession.createReceiver(q1); connection.start(); } public void sendMessageOut(String message) throws JMSException { outMessage.setText(message); queueSender.send(outMessage); } public String receiveMessage() throws Exception { return ((TextMessage) queueReceiver.receive()).getText(); } public void sampleClose() throws JMSException { queueSession.close(); connection.close(); } public static void main(String[] args){ String rec; sample sp = new sample(); try { sp.sampleInit(); sp.sendMessageOut("Hello World!"); java.lang.Thread.sleep(4000); rec=sp.receiveMessage(); System.out.println("Receive text is : "+rec); sp.sampleClose(); }catch(Exception e) { e.printStackTrace(); } }} ...展开收缩
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台，提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。
- 本站已设置防盗链，请勿用迅雷、QQ旋风等多线程下载软件下载资源，下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载，请稍后再次尝试；或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
- 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
