This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a commit to branch test-release in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit fa2219e0fe560f1546eb432b5f4b341a23ee60a4 Author: uglycow <[email protected]> AuthorDate: Wed Jan 15 10:16:50 2020 +0800 typo fix (#1723) --- .../rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java index 4b732a7..e7c7530 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java @@ -561,8 +561,8 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner { } public void seekToEnd(MessageQueue messageQueue) throws MQClientException { - long begin = maxOffset(messageQueue); - this.seek(messageQueue, begin); + long end = maxOffset(messageQueue); + this.seek(messageQueue, end); } private long maxOffset(MessageQueue messageQueue) throws MQClientException {
