This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 7281b5d [ISSUE #3898]fix the spell in MQClientAPIImpl (#3899)
7281b5d is described below
commit 7281b5d9a0db15e5ec1ab9e3444091e7022f65fb
Author: zhangjidi2016 <[email protected]>
AuthorDate: Tue Mar 1 07:48:36 2022 +0800
[ISSUE #3898]fix the spell in MQClientAPIImpl (#3899)
Co-authored-by: zhangjidi2016 <[email protected]>
---
.../src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java | 2 +-
.../java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index 8506432..8dc73ad 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -1022,7 +1022,7 @@ public class MQClientAPIImpl {
this.remotingClient.invokeOneway(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(),
addr), request, timeoutMillis);
}
- public int sendHearbeat(
+ public int sendHeartbeat(
final String addr,
final HeartbeatData heartbeatData,
final long timeoutMillis
diff --git
a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
index 0cc5e3e..d5b9097 100644
---
a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+++
b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -555,7 +555,7 @@ public class MQClientInstance {
}
try {
- int version =
this.mQClientAPIImpl.sendHearbeat(addr, heartbeatData,
clientConfig.getMqClientApiTimeout());
+ int version =
this.mQClientAPIImpl.sendHeartbeat(addr, heartbeatData,
clientConfig.getMqClientApiTimeout());
if
(!this.brokerVersionTable.containsKey(brokerName)) {
this.brokerVersionTable.put(brokerName,
new HashMap<String, Integer>(4));
}