[ https://issues.apache.org/jira/browse/ARTEMIS-1800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16434009#comment-16434009 ]
ASF GitHub Bot commented on ARTEMIS-1800: ----------------------------------------- Github user clebertsuconic commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2009#discussion_r180777030 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java --- @@ -2510,6 +2510,39 @@ public void testSendMessage() throws Exception { Assert.assertEquals(new String(body), "theBody"); } + @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()); + + Field queueMemorySizeField = QueueImpl.class.getDeclaredField("queueMemorySize"); + queueMemorySizeField.setAccessible(true); + final LocalQueueBinding binding = (LocalQueueBinding) server.getPostOffice().getBinding(queue); + Queue q = binding.getQueue(); + AtomicInteger queueMemorySize1 = (AtomicInteger) queueMemorySizeField.get(q); + assertTrue(queueMemorySize1.get() == 0); + + 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()); --- End diff -- ok.. I will just merge it > Incorrect number of messages on queue after remove of scheduled message > ----------------------------------------------------------------------- > > Key: ARTEMIS-1800 > URL: https://issues.apache.org/jira/browse/ARTEMIS-1800 > Project: ActiveMQ Artemis > Issue Type: Bug > Affects Versions: 2.5.0 > Reporter: Justin Bertram > Assignee: Christopher L. Shannon > Priority: Major > > This will reproduce the failure if added to > {{org.apache.activemq.artemis.tests.integration.management.QueueControlTest}}: > {noformat} > @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); > } > {noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)