Github user michaelandrepearce commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2237#discussion_r209386511
--- Diff:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java
---
@@ -1781,6 +1781,66 @@ public void testCountMessagesWithInvalidFilter()
throws Exception {
session.deleteQueue(queue);
}
+ @Test
+ public void testCountMessagesPropertyExist() throws Exception {
+ String key = new String("key_group");
+ String valueGroup1 = "group_1";
+ String valueGroup2 = "group_2";
+
+ SimpleString address = RandomUtil.randomSimpleString();
+ SimpleString queue = RandomUtil.randomSimpleString();
+
+ session.createQueue(address, queue, null, false);
+ ClientProducer producer = session.createProducer(address);
+
+ for (int i = 0; i < 100; i++) {
+ ClientMessage msg = session.createMessage(false);
+ if(i % 3 == 0){
--- End diff --
checkstyle , need to space if and curly
---
