提交 acfe8750 编写于 作者: K KangZhiDong

fix typo

上级 ce4478aa
...@@ -25,7 +25,7 @@ export NAMESRV_ADDR=192.168.0.1:9876;192.168.0.2:9876 ...@@ -25,7 +25,7 @@ export NAMESRV_ADDR=192.168.0.1:9876;192.168.0.2:9876
``` ```
- HTTP static server addressing(default) - HTTP static server addressing(default)
After client started, it will access a http static server address, as: <http://jmenv.tbsite.net:8080/rocketmq/nsaddr>, this URL return the following contents: After client started, it will access an http static server address, as: <http://jmenv.tbsite.net:8080/rocketmq/nsaddr>, this URL return the following contents:
```text ```text
192.168.0.1:9876;192.168.0.2:9876 192.168.0.1:9876;192.168.0.2:9876
......
...@@ -73,7 +73,7 @@ class LocalMessageCache implements ServiceLifecycle { ...@@ -73,7 +73,7 @@ class LocalMessageCache implements ServiceLifecycle {
pullOffsetTable.putIfAbsent(remoteQueue, pullOffsetTable.putIfAbsent(remoteQueue,
rocketmqPullConsumer.fetchConsumeOffset(remoteQueue, false)); rocketmqPullConsumer.fetchConsumeOffset(remoteQueue, false));
} catch (MQClientException e) { } catch (MQClientException e) {
log.error("A error occurred in fetch consume offset process.", e); log.error("An error occurred in fetch consume offset process.", e);
} }
} }
return pullOffsetTable.get(remoteQueue); return pullOffsetTable.get(remoteQueue);
...@@ -124,7 +124,7 @@ class LocalMessageCache implements ServiceLifecycle { ...@@ -124,7 +124,7 @@ class LocalMessageCache implements ServiceLifecycle {
try { try {
rocketmqPullConsumer.updateConsumeOffset(consumeRequest.getMessageQueue(), offset); rocketmqPullConsumer.updateConsumeOffset(consumeRequest.getMessageQueue(), offset);
} catch (MQClientException e) { } catch (MQClientException e) {
log.error("A error occurred in update consume offset process.", e); log.error("An error occurred in update consume offset process.", e);
} }
} }
} }
...@@ -135,7 +135,7 @@ class LocalMessageCache implements ServiceLifecycle { ...@@ -135,7 +135,7 @@ class LocalMessageCache implements ServiceLifecycle {
try { try {
rocketmqPullConsumer.updateConsumeOffset(messageQueue, offset); rocketmqPullConsumer.updateConsumeOffset(messageQueue, offset);
} catch (MQClientException e) { } catch (MQClientException e) {
log.error("A error occurred in update consume offset process.", e); log.error("An error occurred in update consume offset process.", e);
} }
} }
......
...@@ -167,7 +167,7 @@ public class PullConsumerImpl implements PullConsumer { ...@@ -167,7 +167,7 @@ public class PullConsumerImpl implements PullConsumer {
} }
localMessageCache.updatePullOffset(mq, pullResult.getNextBeginOffset()); localMessageCache.updatePullOffset(mq, pullResult.getNextBeginOffset());
} catch (Exception e) { } catch (Exception e) {
log.error("A error occurred in pull message process.", e); log.error("An error occurred in pull message process.", e);
} }
} }
}); });
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册