PROSAGA码农传奇-activemq-将ActiveMQ与多个使用者实例一起使用

<div class =“post-text”itemprop =“text”>
  
    这里的问题是你正在承认来自的消息
     <code>
 QueueBrowser
 </code>
     由于浏览器仅用于浏览消息而不消耗它们，因此该实例不会产生任何影响。
  
   <pre>
 <code>
 ...
QueueBrowser queueBrowser = consumerSession.createBrowser(queue);
Enumeration msgs = queueBrowser.getEnumeration();
while (msgs.hasMoreElements()) {
 ...
 ActiveMQTextMessage message = (ActiveMQTextMessage) msgs.nextElement();
 ...
 try {
 ...
 message.acknowledge(); // this does nothing

</code>
 </pre>
  
    您
    
      是
    
     实际上创造了一个真实的消费和呼唤
     <code>
 consumer.receive(1000)
 </code>
    ，但你丢弃了
     <code>
 Message
 </code>
     例如
     <code>
 receive()
 </code>
     回报。这是
     <code>
 Message
 </code>
     您必须确认实际使用队列中的消息的实例。
  
   <pre>
 <code>
 ...
// Create a message consumer from the session to the queue.
final MessageConsumer consumer = consumerSession.createConsumer(consumerDestination);
...
while (msgs.hasMoreElements()) {
 ...
 try {
 ...
 Message actualMessage = consumer.receive(1000); // acknowledge this!
 ...

</code>
 </pre>
  
    另一个重要注意事项......队列浏览器接收的消息不能保证是队列的静态快照。因此，假设你的呼叫是危险的
     <code>
 consumer.receive(1000)
 </code>
     实际上是
    
      相同
    
     来自队列浏览器的消息。在我看来，你应该重新设计这个逻辑只用于
     <code>
 MessageConsumer
 </code>
     并放弃
     <code>
 QueueBrowser
 </code>
    。
  
</DIV>