Repository: incubator-rocketmq
Updated Branches:
refs/heads/develop 40a233aa0 -> 7c7374e38
Fix issue 165
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/7c7374e3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/7c7374e3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/7c7374e3
Branch: refs/heads/develop
Commit: 7c7374e38c0c1d6e8ee9d704717b2c94b7170a61
Parents: 40a233a
Author: Li Zhanhui <lizhanhui@apache.org>
Authored: Thu Apr 6 16:43:52 2017 +0800
Committer: Zhanhui Li <lizhanhui@apache.org>
Committed: Wed Apr 12 21:51:26 2017 +0800
----------------------------------------------------------------------
.../main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/7c7374e3/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
----------------------------------------------------------------------
diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index 5c2d27f..0edfeec 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -462,7 +462,7 @@ public class DefaultMessageStore implements MessageStore {
long maxPhyOffsetPulling = 0;
int i = 0;
- final int maxFilterMessageCount = 16000;
+ final int maxFilterMessageCount = Math.max(16000, maxMsgNums * ConsumeQueue.CQ_STORE_UNIT_SIZE);
final boolean diskFallRecorded = this.messageStoreConfig.isDiskFallRecorded();
for (; i < bufferConsumeQueue.getSize() && i < maxFilterMessageCount;
i += ConsumeQueue.CQ_STORE_UNIT_SIZE) {
long offsetPy = bufferConsumeQueue.getByteBuffer().getLong();
|