Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-13 21:46:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-6357

Browse Source 
Preventing a divide by 0 error by taking a local reference to the
prefetch size to guarantee that the value doesn't change after the > 0
check

(cherry picked from commit 42dabb7a7a7f981eb57d46663456ac1d7c912acb)
This commit is contained in:
Christopher L. Shannon (cshannon) 2016-07-14 10:07:02 -04:00
parent c3d71ebe01
commit 78cacc5e17
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-broker/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
View File

@ -236,8 +236,9 @@ public abstract class AbstractSubscription implements Subscription {
@Override @Override
public int getInFlightUsage() { public int getInFlightUsage() {
if (info.getPrefetchSize() > 0) { int prefetchSize = info.getPrefetchSize();
return (getInFlightSize() * 100)/info.getPrefetchSize(); if (prefetchSize > 0) {
return (getInFlightSize() * 100) / prefetchSize;
} }
return Integer.MAX_VALUE; return Integer.MAX_VALUE;
} }