Details
-
Bug
-
Resolution: Done
-
Major
-
None
-
None
Description
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.