最近碰JMS碰到一个奇怪的问题,我使用的是Activemq5.2。我实际往一个Queue发布了10条消息,可是实际消费端只接收到5条总是会丢失一半。
我一次次运行,总是第一次丢失再运行一次第二次就能收到了。
可是打开ActiveMQ的WEB控制台,看到的是收到发布10条,收到也是10条。消费端我是异步的接收消息Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
session.createConsumer(request).setMessageListener(new MessageListenerSupport());MessageListenerSupport里的onMessage方法我打印了收到的消息,可是也只有5条。请问这是什么总是?
我一次次运行,总是第一次丢失再运行一次第二次就能收到了。
可是打开ActiveMQ的WEB控制台,看到的是收到发布10条,收到也是10条。消费端我是异步的接收消息Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
session.createConsumer(request).setMessageListener(new MessageListenerSupport());MessageListenerSupport里的onMessage方法我打印了收到的消息,可是也只有5条。请问这是什么总是?
解决方案 »
- 大家觉得Hibernate怎么样?
- netbeans问题
- myeclipse就是比eclipse jee好用,操蛋的eclipse jee, 改变类和配置居然不知道
- 请教struts+spring 怎么用DispatchAction
- 急! 急! 急!跪求正则表达式高手帮忙!!!
- 紧急求助!hibernate的问题!
- 小弟刚学java与struts,对一小段代码不清楚,还请高人指点,问题会者不难,在线等,决解马上解贴
- 大虾,过来看看,Weblogic+EJB的问题!
- 在建CMP/CMR的时候出现了问题!!!
- 大家说怎么开发公用的数据库操作包阿?能不能给个范例阿?
- ibernate 的报异常 请教那位大侠帮我解决啊!我找了好久不找到那出错啊!
- sitemesh问题
1.是不是有两个consumer在subscribe
2.是不是有setJMSMessageID一类的过滤机制再不行就先发10条,先看web控制台是不是剩10条,然后消费端一次一次的运行,运行一次看web控制台是不是显示少了一条消息。