-
Bug
-
Resolution: Done
-
Major
-
None
-
None
messaging-activemq/subsystem/src/main/java/org/wildfly/extension/messaging/activemq/jms/JMSTopicReadAttributeHandler.java
private long getMessagesAdded(AddressControl addressControl, ManagementService managementService) {
List<QueueControl> queues = getQueues(DurabilityType.ALL, addressControl, managementService);
int count = 0;
for (QueueControl queue : queues) {
count += queue.getMessagesAdded();
}
return count;
}
This will get incorrect value if the long value returned from queue.getMessagesAdded() is bigger than Integer.MAX_VALUE.
