From acfe8750f76377b0ec88e4474ea9e392fe92e94d Mon Sep 17 00:00:00 2001 From: KangZhiDong Date: Sun, 1 Sep 2019 04:47:03 +0800 Subject: [PATCH] fix typo --- docs/en/Configuration_Client.md | 2 +- .../openmessaging/rocketmq/consumer/LocalMessageCache.java | 6 +++--- .../openmessaging/rocketmq/consumer/PullConsumerImpl.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/docs/en/Configuration_Client.md b/docs/en/Configuration_Client.md index 4b6d2fe3..a684a8a4 100644 --- a/docs/en/Configuration_Client.md +++ b/docs/en/Configuration_Client.md @@ -25,7 +25,7 @@ export NAMESRV_ADDR=192.168.0.1:9876;192.168.0.2:9876 ``` - HTTP static server addressing(default) -After client started, it will access a http static server address, as: , this URL return the following contents: +After client started, it will access an http static server address, as: , this URL return the following contents: ```text 192.168.0.1:9876;192.168.0.2:9876 diff --git a/openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/LocalMessageCache.java b/openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/LocalMessageCache.java index 93e60a73..d2fc6781 100644 --- a/openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/LocalMessageCache.java +++ b/openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/LocalMessageCache.java @@ -73,7 +73,7 @@ class LocalMessageCache implements ServiceLifecycle { pullOffsetTable.putIfAbsent(remoteQueue, rocketmqPullConsumer.fetchConsumeOffset(remoteQueue, false)); } 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); @@ -124,7 +124,7 @@ class LocalMessageCache implements ServiceLifecycle { try { rocketmqPullConsumer.updateConsumeOffset(consumeRequest.getMessageQueue(), offset); } 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 { try { rocketmqPullConsumer.updateConsumeOffset(messageQueue, offset); } 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); } } diff --git a/openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PullConsumerImpl.java b/openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PullConsumerImpl.java index d6735100..945ecfac 100644 --- a/openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PullConsumerImpl.java +++ b/openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PullConsumerImpl.java @@ -167,7 +167,7 @@ public class PullConsumerImpl implements PullConsumer { } localMessageCache.updatePullOffset(mq, pullResult.getNextBeginOffset()); } catch (Exception e) { - log.error("A error occurred in pull message process.", e); + log.error("An error occurred in pull message process.", e); } } }); -- GitLab