jiulinxiri/rocketmq-dashboard
1
0
Fork 0
mirror of https://github.com/apache/rocketmq-dashboard.git synced 2025-09-10 19:48:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix GroupConsumeInfo#compareTo (#326)

Browse Source
This commit is contained in:
James Yin
2020-08-04 17:32:32 +08:00
committed by GitHub
parent 970e718413
commit 3c32be5ace
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java
View File

@@ -71,10 +71,9 @@ public class GroupConsumeInfo implements Comparable<GroupConsumeInfo> {
@Override @Override
public int compareTo(GroupConsumeInfo o) { public int compareTo(GroupConsumeInfo o) {
if (this.count != o.count) { if (this.count != o.count) {
return o.count - this.count; return Integer.compare(o.count, this.count);
} }
return Long.compare(o.diffTotal, this.diffTotal);
return (int) (o.diffTotal - diffTotal);
} }
public int getConsumeTps() { public int getConsumeTps() {