commit | 8b7f10dfa19e65a20be4e888f33ca8d5fc737bb6 | [log] [tgz] |
---|---|---|
author | James Yin <ywhjames@hotmail.com> | Tue Aug 04 17:32:32 2020 +0800 |
committer | GitHub <noreply@github.com> | Tue Aug 04 17:32:32 2020 +0800 |
tree | 00d8db0050449a808cde7b6481429d67f40b2b1f | |
parent | 1be81fb993a555d98d4029fe5fac7c18dd8535ce [diff] |
fix GroupConsumeInfo#compareTo (#326)
diff --git a/rocketmq-console/src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java b/rocketmq-console/src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java index 27c5f92..5d81f2e 100644 --- a/rocketmq-console/src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java +++ b/rocketmq-console/src/main/java/org/apache/rocketmq/console/model/GroupConsumeInfo.java
@@ -71,10 +71,9 @@ @Override public int compareTo(GroupConsumeInfo o) { if (this.count != o.count) { - return o.count - this.count; + return Integer.compare(o.count, this.count); } - - return (int) (o.diffTotal - diffTotal); + return Long.compare(o.diffTotal, this.diffTotal); } public int getConsumeTps() {