Skip to content

R
Rocketmq

super-server / Rocketmq
与 Fork 源项目一致

Fork自 Apache RocketMQ / Rocketmq

通知 2
Star 0
Fork 0
R
Rocketmq

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 881f7675 编写于 作者: U uglycow 提交者： Heng Du
浏览文件
操作

typo fix (#1723)

上级 678cab39
隐藏空白更改
内联 并排
Showing with 2 addition and 2 deletion
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
浏览文件 @ 881f7675
...@@ -561,8 +561,8 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner { ...@@ -561,8 +561,8 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner {
} }
public void seekToEnd(MessageQueue messageQueue) throws MQClientException { public void seekToEnd(MessageQueue messageQueue) throws MQClientException {
long begin = maxOffset(messageQueue); long end = maxOffset(messageQueue);
this.seek(messageQueue, begin); this.seek(messageQueue, end);
} }
private long maxOffset(MessageQueue messageQueue) throws MQClientException { private long maxOffset(MessageQueue messageQueue) throws MQClientException {
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或