Fix: msg rate acquire permit for msg/bytes (#716)

apache · Aug 26, 2017 · a64d795 · a64d795
1 parent 21a618a
commit a64d795
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...va/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java b/...va/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
@@ -354,8 +354,8 @@ public synchronized void readEntriesComplete(List<Entry> entries, Object ctx) {
                 start += messagesForC;
                 entriesToDispatch -= messagesForC;
                 totalAvailablePermits -= msgSent;
-                totalMessagesSent += sentMsgInfo.getTotalSentMessageBytes();
-                totalBytesSent += sentMsgInfo.getTotalSentMessages();
+                totalMessagesSent += sentMsgInfo.getTotalSentMessages();
+                totalBytesSent += sentMsgInfo.getTotalSentMessageBytes();
             }
         }