提交 1c02afd1 编写于 作者: R rongtong 提交者: Heng Du

fix(litePullConsumer):delete invalid method to get next pullBatchSize (#1702)

上级 f7c21db6
......@@ -211,10 +211,6 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner {
}
}
private int nextPullBatchSize() {
return Math.min(this.defaultLitePullConsumer.getPullBatchSize(), consumeRequestCache.remainingCapacity());
}
public synchronized void shutdown() {
switch (this.serviceState) {
case CREATE_JUST:
......@@ -775,7 +771,8 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner {
subscriptionData = FilterAPI.buildSubscriptionData(defaultLitePullConsumer.getConsumerGroup(),
topic, SubscriptionData.SUB_ALL);
}
PullResult pullResult = pull(messageQueue, subscriptionData, offset, nextPullBatchSize());
PullResult pullResult = pull(messageQueue, subscriptionData, offset, defaultLitePullConsumer.getPullBatchSize());
switch (pullResult.getPullStatus()) {
case FOUND:
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册