| 发表于:2007-09-03 08:01:45 楼主 |
package my; import javax.jms.*; import javax.naming.*; import java.util.*; public class client{ public static void main(string bb[]) throws exception{ properties h=new properties(); h.put(context.initial_context_factory, "weblogic.jndi.wlinitialcontextfactory "); h.put(context.provider_url, "t3://localhost:7001 "); initialcontext ic = new initialcontext(h); topicconnectionfactory factory = (topicconnectionfactory) ic.lookup( "myjmsfatory "); topicconnection con = factory.createtopicconnection(); topicsession session = con.createtopicsession(false,session.auto_acknowledge); topic q = (topic) ic.lookup( "myjmstopic "); topicpublisher sender = session.createpublisher(q); textmessage message = session.createtextmessage(); con.start(); message.settext( "hello jms ! "); sender.send(message); con.close(); } } jb提示这一句有问题. sender.send(message); 我感觉代码好像没问题. |
|
|
|
|