luyuanwu003的个人资料

activemq的topic消息一直都会存在数据库中，为什么不会删除我把消息设置的持久化到数据库。采用topic的方式发送消息。每次发送消息之后，数据库的ACTIVEMQ_MSGS表里都会插入10条记录（每次是发送10条消息），在接收端接收消息之后，ACTIVEMQ_MSGS表里的数据没有被删掉，求大神帮忙给看看。（采用queue方式发送消息，接收端没接收消息之前，ACTIVEMQ_MSGS表里有数据，接收之后ACTIVEMQ_MSGS的数据库就自动被删掉了）发送端的代码如下； import javax.jms.Connection; import javax.jms.DeliveryMode; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; import org.apache.activemq.ActiveMQConnectionFactory; public class TopicPublisher { public static void main(String[] args) throws JMSException { ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = factory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Topic topic = session.createTopic("myTopic.messages"); MessageProducer producer = session.createProducer(topic); producer.setDeliveryMode(DeliveryMode.PERSISTENT); for(int i =0;i<10;i++){ TextMessage message = session.createTextMessage(); message.setText("message_" + System.currentTimeMillis()); producer.send(message); System.out.println("Sent message: " + message.getText()); // try { // Thread.sleep(1000); // } catch (InterruptedException e) { // e.printStackTrace(); // } } session.close(); connection.stop(); connection.close(); } } 接收端的代码如下： import javax.jms.Connection; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageListener; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; import org.apache.activemq.ActiveMQConnectionFactory; public class TopicSubscriber { /** * @param args */ public static void main(String[] args) { ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616"); try { Connection connection = factory.createConnection(); connection.setClientID("null"); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Topic topic = session.createTopic("myTopic.messages"); MessageConsumer consumer = session.createDurableSubscriber(topic,"123"); consumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { TextMessage tm = (TextMessage) message; try { System.out.println("Received message: " + tm.getText()); } catch (JMSException e) { e.printStackTrace(); } } }); } catch (JMSException e) { e.printStackTrace(); } } }

T285车次早上看还有，现在看就没这个车次了，如标题，有人知道是怎么回事吗？求解释，还想明天买这趟车

诚心求医本人男，24岁。现在频繁遗精，上次去医院，被医生怀疑是前列腺炎，检查了很多项，发现前列腺没什么问题。求大神给看看是什么问题

如何给香港电话号码充值急急急请问如何给香港号码充值，我手机的来电显示是85295698498，请问如何给这个号码充值

新人求问佣金问题这是我的交割单，我的佣金是不是4.92/900 = 0.00546666?

耒阳火车站有自动取票机吗？耒阳火车站、西站有自动取票机吗？

求回答，衡阳火车站有自动取票机吗？求回答，衡阳火车站有自动取票机吗？有知道的吗？

求解答！深圳是不是只有一个东门大街，是在龙岗区求解答！深圳是不是只有一个东门大街，是在龙岗区多谢

记2013-01-05 又是一天过去了。今天工作有了一些进展，但是还是有些不顺，工作中的问题还是不断的出现，印证了一个同学说的“人生就是在不断的解决问题”的那句话。工资卡上数字还是准时地增长了一些，但我却没有了第一次发工资时的热情。才

m2 32g号一个 10元拿走，要的速度联系 m2 32g号一个 10元拿走，要的速度联系 qq:71424048

小米2 32g资格出售要的速度联系小米2 32g资格出售要的速度联系 qq:71424048

失眠的人伤不起啊有木有失眠的人伤不起啊有木有

今晚有更吗今晚有更吗

大家坐公交去火车站的时候，小心保管自己的财务刚才我坐的那个公交车上，一个小女生的钱包被偷了，包里有车票，各种卡。小姑娘都急哭了。大家回家的时候都小心点

求462的下载地址找不到462的下载地址了，知道的给发一个，谢谢了

求助：永丰附近哪有给笔记本电脑清灰的地方刚来北京，电脑风扇声音太大，想清一下灰。谁知道永丰附近有笔记本清灰的地方吗？麻烦告知，在线等。谢谢了

我今天入住本吧，现在就到3级了，庆祝一下我今天入住本吧，现在就到3级了，庆祝一下

吧里有在北京读书的同学吗？吧里有在北京读书的同学吗？想问问春运时，你们自己能在火车站买到回家的票吗？

话说要真正实行了实名制买票、验票，能完全杜绝黄牛吗？话说要真正实行了实名制买票、验票，能完全杜绝黄牛吗？

我的学生证的乘车区间是沈阳到衡阳，我可以买北京到长沙的学生票吗我的学生证的乘车区间是沈阳到衡阳，我可以买北京到长沙的学生票吗？

春运的时候北京火车站会实行实名制吗春运的时候北京火车站会实行实名制吗

有个怪病，请各位名医帮忙看一下我从小手掌和脚掌出汗就出的非常厉害，到现在还是一样，下雪天都出汗，这大概是什么原因造成的？

还有没睡的没，失眠的人伤不起啊还有没睡的没，失眠的人伤不起啊

刚交了女朋友（异地的），平时联系的时候该和她聊些什么本人初恋，她也是。请各位高人指点，在平时和她的联系中该聊些什么好

表白成功求祝福 11点我表白成功，求祝福

表白成功，求祝福昨晚11点表白成功，求祝福

上海二区找师傅本人在上海二区，以前都是自己瞎打，技术不好，想找个师傅带 qq：71424048