2 Replies Latest reply on Jan 11, 2010 4:46 AM by Andy Taylor

    Odd code in QueueImpl::deleteMatchingReferences

    Tim Fox Master

      List<MessageReference> cancelled = scheduledDeliveryHandler.cancel();
               for (MessageReference messageReference : cancelled)
               {
                  if (filter == null || filter.match(messageReference.getMessage()))
                  {
                     deliveringCount.incrementAndGet();
                     acknowledge(tx, messageReference);
                     count++;
                  }
               }

       

      Why is it cancelling ALL the scheduled refs?