持久订阅问题 既然是持久的,JMS实现的时候应该会把它保存到数据库或文件中。像weblogic就是保存到oracle 解决方案 » 免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货 wls 可以配置保存到数据库或者文件中Services-->JMS-->Stores 是的WL是可以那样做的,但OC4J中呢?谢谢!! 按照JMS规范,持久订阅的时候,消息保存到过期或被客户接收,可是我的客户为什么可以重复收到相同的消息? 可能每次你的客户的clientid不同 我用的 都是 同 一个 CLIENTID啊 // System.out.println("test!"); connectionFC = (TopicConnectionFactory) ctx.lookup("myMDBFC"); // System.out.println("test!"); topicConnection = connectionFC.createTopicConnection(); topicConnection.setClientID("msg"); topicSession = topicConnection.createTopicSession(true, 0); // System.out.println("test!"); topic = (Topic) ctx.lookup("myTopic"); // System.out.println("test!"); subscriber = topicSession.createDurableSubscriber(topic,"subname"); System.out.println("listener!"); // MessageThread t=new MessageThread(); subscriber.setMessageListener(this); System.out.println("listener!"); topicConnection.start(); topicConnection.setClientID("msg");subscriber = topicSession.createDurableSubscriber(topic,"subname");两个clientid不同改为subscriber = topicSession.createDurableSubscriber(topic,"msg");应该就好了 java数据库处理问题 大家好,问一个jasper-compiler.jar包冲突的问题 异地大屏幕内容发布系统 设置下拉框的默认值 高手帮帮忙呀,结业作业!!!(一个Java程序) 如何在不同的weblogic应用之间传递session变量 hibernate多表查询时为什么用<one-to-many>??? 一个SQL语句 大家看下 用hibernate执行distinct报错!!!! 想用MapInfo做二次开发,请问mapinfo有没有java接口? PetStore 中EJB设计模式的DAO模式问题,大家帮我一下. 哪个JMS高手写个从MDB里接收消息的客户程序?谢谢!!
Services-->JMS-->Stores
可以重复收到相同的消息?
connectionFC = (TopicConnectionFactory) ctx.lookup("myMDBFC");
// System.out.println("test!");
topicConnection = connectionFC.createTopicConnection();
topicConnection.setClientID("msg");
topicSession = topicConnection.createTopicSession(true, 0);
// System.out.println("test!");
topic = (Topic) ctx.lookup("myTopic");
// System.out.println("test!");
subscriber = topicSession.createDurableSubscriber(topic,"subname");
System.out.println("listener!");
// MessageThread t=new MessageThread();
subscriber.setMessageListener(this);
System.out.println("listener!");
topicConnection.start();
subscriber = topicSession.createDurableSubscriber(topic,"subname");
两个clientid不同
改为
subscriber = topicSession.createDurableSubscriber(topic,"msg");
应该就好了