ActiveMQ求助

一号男嘉宾 发布于 2013/08/27 08:49
阅读 220
收藏 0


RT,我生产者的Session session = connection.createSession(Boolean.TRUE, Session.CLIENT_ACKNOWLEDGE);表示启用事务。

消费者的            session = connection.createSession(Boolean.TRUE,
                    Session.CLIENT_ACKNOWLEDGE);

            while (true) {
                //设置接收者接收消息的时间,为了便于测试,这里谁定为100s
                TextMessage message = (TextMessage) consumer.receive();
              // message.acknowledge();
                if (null != message) {
                    System.out.println("收到消息" + message.getText());
                 message.acknowledge();
                } else {
                    break;
                }
                  message.acknowledge();
            }
我每个消息都有手懂确认message.acknowledge();现在的问题是,我的这些消息每次都显示,也就是处于未读状态,我每条都确认了为什么还是处理未读状态呢?会的兄弟指教一下。


加载中
返回顶部
顶部