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

https://issues.apache.org/jira/browse/AMQ-6435 - destination mbean query api, return the right count

This commit is contained in:
Dejan Bosanac 2016-09-27 12:53:49 +02:00
parent 63d62a71f5
commit e8ba0b0119
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationsViewFilter.java
View File

@ -127,29 +127,28 @@ public class DestinationsViewFilter implements Serializable {
*/
String filter(int page, int pageSize) throws IOException {
ObjectMapper mapper = new ObjectMapper();
Map<ObjectName, DestinationView> filtered = getFilteredDestinations(page, pageSize);
destinations = Maps.filterValues(destinations, getPredicate());
Map<ObjectName, DestinationView> pagedDestinations = getPagedDestinations(page, pageSize);
Map<String, Object> result = new HashMap<String, Object>();
result.put("data", filtered);
result.put("data", pagedDestinations);
result.put("count", destinations.size());
StringWriter writer = new StringWriter();
mapper.writeValue(writer, result);
return writer.toString();
}
Map<ObjectName, DestinationView> getFilteredDestinations(int page, int pageSize) {
Map<ObjectName, DestinationView> filtered = Maps.filterValues(destinations, getPredicate());
Map<ObjectName, DestinationView> getPagedDestinations(int page, int pageSize) {
ImmutableMap.Builder<ObjectName, DestinationView> builder = ImmutableMap.builder();
int start = (page - 1) * pageSize;
int end = Math.min(page * pageSize, filtered.size());
int end = Math.min(page * pageSize, destinations.size());
int i = 0;
for (Map.Entry<ObjectName, DestinationView> entry :
getOrdering().sortedCopy(filtered.entrySet())) {
getOrdering().sortedCopy(destinations.entrySet())) {
if (i >= start && i < end) {
builder.put(entry.getKey(), entry.getValue());
}
i++;
}
return builder.build();
}