[
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)
