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?