[ARTEMIS-1800] Incorrect number of messages on queue after remove of scheduled message

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.5.0
• Fix Version/s: 2.6.0
• Assignee: Christopher L. Shannon
• Reporter: Justin Bertram
• Created: 10/Apr/18 15:37
• Updated: 17/May/18 02:43
• Resolved: 17/May/18 02:43

Description

This will reproduce the failure if added to org.apache.activemq.artemis.tests.integration.management.QueueControlTest:

   @Test
   public void testGetScheduledCountOnRemove() throws Exception {
      long delay = Integer.MAX_VALUE;
      SimpleString address = RandomUtil.randomSimpleString();
      SimpleString queue = RandomUtil.randomSimpleString();

      session.createQueue(address, RoutingType.MULTICAST, queue, null, durable);

      QueueControl queueControl = createManagementControl(address, queue);
      Assert.assertEquals(0, queueControl.getScheduledCount());

      ClientProducer producer = session.createProducer(address);
      ClientMessage message = session.createMessage(durable);
      message.putLongProperty(Message.HDR_SCHEDULED_DELIVERY_TIME, System.currentTimeMillis() + delay);
      producer.send(message);

      queueControl.removeAllMessages();

      Assert.assertEquals(0, queueControl.getMessageCount());

      session.deleteQueue(queue);
   }

Issue Links

• is caused by: ARTEMIS-1663 Add enhanced message count and size metrics for Queues
• links to: GitHub Pull Request #2008
• links to: GitHub Pull Request #2009