＋设为首页 ＋添加到收藏夹
三个java文件:
package com.lizongbo.jmsdemo; 【程序编程相关: Tomcat5配置Mysql JDBC】
jmstest.java 【推荐阅读:怎样用jb建立ofbiz3的应用 】
/** <p>title:jms demo </p> 【扩展信息:定义自己的Connection Pool】
import javax.jms.messagelistener;import javax.naming.context;import javax.jms.queueconnectionfactory;import javax.jms.queueconnection;import javax.jms.queuesession;import javax.jms.queuesender;import javax.jms.queuereceiver;import javax.jms.queue;import java.io.serializable;import java.util.properties;import javax.jms.message;import javax.jms.jmsexception;
<p>description: </p>
<p>copyright: copyright (c) 2005</p>
<p>company: </p>
@author lizongbo @version 1.0
* use this class to send and receive point-to-point messages. * to send a text message: * <code> * jmstest jmstest = new jmstest(); * jmstest.sendtext("hello world"); * jmstest.close(); //release resources * </code>
* to receive a message: * <code> * jmstest jmstest = new jmstest(); * jmstest.getqueuereceiver(); * </code> */public class jmstest implements messagelistener { private static context context; private boolean transacted = true; private int acknowledgementmode = javax.jms.session.auto_acknowledge; private queueconnectionfactory queueconnectionfactory; private queueconnection queueconnection; private queuesession queuesession; private queuesender queuesender; private queuereceiver queuereceiver; private queue queue; private string queueconnectionfactoryname = "testjms"; private string sendqueuename = "com.lizongbo.jms001"; private string recvqueuename = "com.lizongbo.jms001"; public void settransacted(boolean transacted) { this.transacted = transacted; }
public void sendobject(serializable message) throws exception { javax.jms.objectmessage objectmessage = getqueuesession(). createobjectmessage(); objectmessage.clearbody(); objectmessage.setobject(message); getqueuesender().send(objectmessage); if (istransacted()) { getqueuesession().commit(); } }
public void sendtext(string message) throws exception { javax.jms.textmessage textmessage = getqueuesession().createtextmessage(); textmessage.clearbody(); textmessage.settext(message); getqueuesender().send(textmessage); if (istransacted()) { getqueuesession().commit(); } }
public queuereceiver getqueuereceiver() throws exception { if (queuereceiver == null) { queuereceiver = getqueuesession().createreceiver(getrecvqueue()); queuereceiver.setmessagelistener(this); } return queuereceiver; }
... 下一页