Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #1728

This commit is contained in:
Clebert Suconic 2017-12-19 09:35:18 -05:00
parent a081a1e2bb c202b18d44
commit a3d297ff9a
2 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ManagementWithPagingServerTest.java
View File

@ -145,7 +145,9 @@ public class ManagementWithPagingServerTest extends ManagementTestBase {
Assert.assertNotNull(jsonString);
JsonArray array = JsonUtil.readJsonArray(jsonString);
Assert.assertEquals(num / 2, array.size());
Assert.assertEquals(matchingValue, array.getJsonObject(0).getJsonNumber("key").longValue());
long l = Long.parseLong(array.getJsonObject(0).get("key").toString().replaceAll("\"", ""));
Assert.assertEquals(matchingValue, l);
long n = queueControl.countMessages(filter);
assertEquals(num / 2, n);

18
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java
View File

@ -533,7 +533,7 @@ public class QueueControlTest extends ManagementTestBase {
Map<String, Object>[] messages = queueControl.listScheduledMessages();
Assert.assertEquals(1, messages.length);
Assert.assertEquals(intValue, ((Number) messages[0].get("key")).intValue());
Assert.assertEquals(intValue, Integer.parseInt((messages[0].get("key")).toString()));
Thread.sleep(delay + 500);
@ -567,7 +567,8 @@ public class QueueControlTest extends ManagementTestBase {
Assert.assertNotNull(jsonString);
JsonArray array = JsonUtil.readJsonArray(jsonString);
Assert.assertEquals(1, array.size());
Assert.assertEquals(intValue, array.getJsonObject(0).getJsonNumber("key").intValue());
int i = Integer.parseInt(array.getJsonObject(0).get("key").toString().replaceAll("\"", ""));
Assert.assertEquals(intValue, i);
Thread.sleep(delay + 500);
@ -700,7 +701,9 @@ public class QueueControlTest extends ManagementTestBase {
Assert.assertNotNull(jsonString);
JsonArray array = JsonUtil.readJsonArray(jsonString);
Assert.assertEquals(1, array.size());
Assert.assertEquals(intValue, array.getJsonObject(0).getInt("key"));
long l = Long.parseLong(array.getJsonObject(0).get("key").toString().replaceAll("\"", ""));
Assert.assertEquals(intValue, l);
consumeMessages(1, session, queue);
@ -735,7 +738,7 @@ public class QueueControlTest extends ManagementTestBase {
Map<String, Object>[] messages = queueControl.listMessages(filter);
Assert.assertEquals(1, messages.length);
Assert.assertEquals(matchingValue, messages[0].get("key"));
Assert.assertEquals(matchingValue, Long.parseLong(messages[0].get("key").toString()));
consumeMessages(2, session, queue);
@ -816,7 +819,9 @@ public class QueueControlTest extends ManagementTestBase {
Assert.assertNotNull(jsonString);
JsonArray array = JsonUtil.readJsonArray(jsonString);
Assert.assertEquals(1, array.size());
Assert.assertEquals(matchingValue, array.getJsonObject(0).getJsonNumber("key").longValue());
long l = Long.parseLong(array.getJsonObject(0).get("key").toString().replaceAll("\"", ""));
Assert.assertEquals(matchingValue, l);
consumeMessages(2, session, queue);
@ -1418,7 +1423,8 @@ public class QueueControlTest extends ManagementTestBase {
// the message IDs are set on the server
Map<String, Object>[] messages = queueControl.listMessages(null);
Assert.assertEquals(50, messages.length);
assertEquals(50, ((Number) messages[0].get("count")).intValue());
int i = Integer.parseInt((messages[0].get("count")).toString());
assertEquals(50, i);
long messageID = (Long) messages[0].get("messageID");
// delete 1st message