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));
                                 }

Reply via email to